Method openSpiteStream

internal/bridge/bridge.go:210–217

()

}

func (b *Bridge) openSpiteStream() error {
	stream, err := b.rpc.SpiteStream(b.pipelineContext())
	if err != nil {
		return err
	}
	b.spiteStream = stream
	return nil
}

// listenerContext returns a gRPC context with listener_id metadata.
func (b *Bridge) listenerContext() context.Context {