snapshotreceiver

Documentation

Index

• func New(receiverCfg map[string]interface{}, pusher SnapshotPusher, ...) (services.Service, tp.SnapshotServiceServer, error)
• type Middleware
  • func FakeTenantMiddleware() Middleware
  • func MultiTenancyMiddleware() Middleware
• type SnapshotPusher
• type SnapshotReceiver

Functions

func New

func New(receiverCfg map[string]interface{}, pusher SnapshotPusher, middleware Middleware, logger gkLog.Logger) (services.Service, tp.SnapshotServiceServer, error)

New creates a new snapshotReceiver that can accept and process snapshots

Types

type Middleware

type Middleware interface {
	WrapPoll(poll receivers.ProcessPoll) receivers.ProcessPoll
	WrapSnapshots(snap receivers.ProcessSnapshots) receivers.ProcessSnapshots
}

Middleware is used to intercept GRPC and HTTP calls from receivers and ensure that the x-scope-orgid header is available

func FakeTenantMiddleware

func FakeTenantMiddleware() Middleware

func MultiTenancyMiddleware

func MultiTenancyMiddleware() Middleware

type SnapshotPusher

type SnapshotPusher interface {
	PushSnapshot(ctx context.Context, snapshot *tp.Snapshot) (*tp.SnapshotResponse, error)
	PushPoll(ctx context.Context, pollRequest *pb.PollRequest) (*pb.PollResponse, error)
}

type SnapshotReceiver

type SnapshotReceiver struct {
	tp.UnimplementedSnapshotServiceServer
}