grpcmanager

type Batcher ¶

type Batcher interface {
	BatchCounter(name string) metricbatcher.BatchCounterChainer
}

type DataDumper ¶

type DataDumper interface {
	LatestContainerMetrics(appID string) []*events.Envelope
	RecentLogsFor(appID string) []*events.Envelope
}

DataDumper dumps Envelopes for container metrics and recent logs requests.

type DataSetter ¶

type DataSetter interface {
	Set(data []byte)
}

DataSetter accepts writes of marshalled data.

type GRPCManager ¶

type GRPCManager struct {
	// contains filtered or unexported fields
}

GRPCManager is the GRPC server component that accepts requests for firehose streams, application streams, container metrics, and recent logs.

func New(registrar Registrar, dumper DataDumper) *GRPCManager

func (m *GRPCManager) Alert(missed int)

func (m *GRPCManager) ContainerMetrics(ctx context.Context, req *plumbing.ContainerMetricsRequest) (*plumbing.ContainerMetricsResponse, error)

func (m *GRPCManager) RecentLogs(ctx context.Context, req *plumbing.RecentLogsRequest) (*plumbing.RecentLogsResponse, error)

func (m *GRPCManager) Subscribe(req *plumbing.SubscriptionRequest, sender plumbing.Doppler_SubscribeServer) error

type IngestorGRPCServer ¶

type IngestorGRPCServer interface {
	plumbing.DopplerIngestor_PusherServer
}

type IngestorManager ¶

type IngestorManager struct {
	// contains filtered or unexported fields
}

func NewIngestor(sender MessageSender, batcher Batcher) *IngestorManager

func (i *IngestorManager) Pusher(pusher plumbing.DopplerIngestor_PusherServer) error

type MessageSender ¶

type MessageSender interface {
	Set(*events.Envelope)
}

type Registrar ¶

type Registrar interface {
	Register(req *plumbing.SubscriptionRequest, setter DataSetter) func()
}

Registrar registers stream and firehose DataSetters to accept reads.

type Router ¶

type Router struct {
	// contains filtered or unexported fields
}

func NewRouter() *Router

func (r *Router) Register(req *plumbing.SubscriptionRequest, dataSetter DataSetter) (cleanup func())

func (r *Router) SendTo(appID string, envelope *events.Envelope)