sinker

Documentation

Index

• Constants
• Variables
• type Service
  • func New(logger *zap.Logger, pubSub mfnats.PubSub, esclient *redis.Client, ...) Service

Constants

const (
	HeartbeatFreq  = 60 * time.Second
	DefaultTimeout = 30 * time.Minute
)

const (
	BackendMetricsTopic = "be.*.m.>"
	MaxMsgPayloadSize   = 1024 * 100
)

Variables

var (
	ErrPayloadTooBig = errors.New("payload too big")
)

Types

type Service

type Service interface {
	// Start set up communication with the message bus to communicate with agents
	Start() error
	// Stop end communication with the message bus
	Stop() error
}

func New

func New(logger *zap.Logger,
	pubSub mfnats.PubSub,
	esclient *redis.Client,
	configRepo config.ConfigRepo,
	policiesClient policiespb.PolicyServiceClient,
	fleetClient fleetpb.FleetServiceClient,
	sinksClient sinkspb.SinkServiceClient,
) Service

New instantiates the sinker service implementation.