Struct pushStreamServer

pkg/ingester/pushstream_security_test.go:25–31

pushStreamServer is a mock implementation of Ingester_PushStreamServer for testing PushStream. Context() injects stream-level authentication (X-Scope-OrgID), and Recv() provides the sequence of StreamWriteRequests sent by the client.

// Context() injects stream-level authentication (X-Scope-OrgID),
// and Recv() provides the sequence of StreamWriteRequests sent by the client.
type pushStreamServer struct {
	grpc.ServerStream
	ctx      context.Context
	requests []*cortexpb.StreamWriteRequest
	idx      int
	sent     []*cortexpb.WriteResponse
}

func (s *pushStreamServer) Context() context.Context { return s.ctx }