Function StartUpstreamServer

helper/server/upstream.go:42–75

StartUpstreamServer starts a new upstream server with the given reader and writer

(reader io.Reader, writer io.Writer, options *UpstreamOptions)

// StartUpstreamServer starts a new upstream server with the given reader and writer
func StartUpstreamServer(reader io.Reader, writer io.Writer, options *UpstreamOptions) error {
	pipe := util.NewStdStreamJoint(reader, writer, options.ExitOnClose)
	lis := util.NewStdinListener()
	done := make(chan error)

	// Compile ignore paths
	ignoreMatcher, err := ignoreparser.CompilePaths(options.ExludePaths, logpkg.Discard)
	if err != nil {
		return errors.Wrap(err, "compile paths")
	}

	go func() {
		s := grpc.NewServer()
		upstream := &Upstream{
			options:       options,
			ignoreMatcher: ignoreMatcher,
			ping:          &pingtimeout.PingTimeout{},
		}

		if options.Ping {
			doneChan := make(chan struct{})
			defer close(doneChan)
			upstream.ping.Start(doneChan)
		}

		remote.RegisterUpstreamServer(s, upstream)
		reflection.Register(s)

		done <- s.Serve(lis)
	}()

	lis.Ready(pipe)
	return <-done
}

// Upstream is the implementation for the upstream server
type Upstream struct {