bridgeservice

Documentation

Index

• type BridgeService
• type SinkerOtelBridgeService
  • func NewBridgeService(logger *zap.Logger, sinkerCache config.ConfigRepo, ...) SinkerOtelBridgeService
  • func (bs *SinkerOtelBridgeService) ExtractAgent(ctx context.Context, channelID string) (*fleetpb.AgentInfoRes, error)
  • func (bs *SinkerOtelBridgeService) GetSinkIdsFromAgentGroups(ctx context.Context, mfOwnerId string, agentGroupIds []string) (map[string]string, error)
  • func (bs *SinkerOtelBridgeService) NotifyActiveSink(_ context.Context, mfOwnerId, sinkId, newState, message string) error

Types

type BridgeService

type BridgeService interface {
	ExtractAgent(ctx context.Context, channelID string) (*fleetpb.AgentInfoRes, error)
	GetDataSetsFromAgentGroups(ctx context.Context, mfOwnerId string, agentGroupIds []string) (map[string]string, error)
	NotifyActiveSink(ctx context.Context, mfOwnerId, sinkId, state, message string) error
}

type SinkerOtelBridgeService

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

func NewBridgeService

func NewBridgeService(logger *zap.Logger,
	sinkerCache config.ConfigRepo,
	policiesClient policiespb.PolicyServiceClient,
	fleetClient fleetpb.FleetServiceClient) SinkerOtelBridgeService

func (*SinkerOtelBridgeService) ExtractAgent

func (bs *SinkerOtelBridgeService) ExtractAgent(ctx context.Context, channelID string) (*fleetpb.AgentInfoRes, error)

func (*SinkerOtelBridgeService) GetSinkIdsFromAgentGroups

func (bs *SinkerOtelBridgeService) GetSinkIdsFromAgentGroups(ctx context.Context, mfOwnerId string, agentGroupIds []string) (map[string]string, error)

func (*SinkerOtelBridgeService) NotifyActiveSink

func (bs *SinkerOtelBridgeService) NotifyActiveSink(_ context.Context, mfOwnerId, sinkId, newState, message string) error