integration

Documentation

Index

• Variables
• type DrpcIntegrationClient
  • func NewDrpcIntegrationClient(drpcIntegration *config.DrpcIntegrationConfig) *DrpcIntegrationClient
  • func NewDrpcIntegrationClientWithConnector(ctx context.Context, connector drpc.DrpcHttpConnector, ...) *DrpcIntegrationClient
  • func (d *DrpcIntegrationClient) GetStatsSchema() []statsdata.StatsDims
  • func (d *DrpcIntegrationClient) InitKeys(_ string, cfg config.IntegrationKeyConfig) (chan keydata.KeyEvent, error)
  • func (d *DrpcIntegrationClient) ProcessStatsData(statsMap statsData) error
  • func (d *DrpcIntegrationClient) Type() IntegrationType
• type DrpcOwnedKey
• type IntegrationClient
• type IntegrationResolver
  • func NewIntegrationResolver(cfg *config.IntegrationConfig) *IntegrationResolver
  • func NewNewIntegrationResolverWithClients(clients map[IntegrationType]IntegrationClient) *IntegrationResolver
  • func (i *IntegrationResolver) GetIntegration(integrationType IntegrationType) IntegrationClient
• type IntegrationType
  • func GetIntegrationType(configType config.IntegrationType) IntegrationType
• type LocalIntegration
  • func NewLocalIntegration() *LocalIntegration
  • func (l *LocalIntegration) GetStatsSchema() []statsdata.StatsDims
  • func (l *LocalIntegration) InitKeys(id string, cfg config.IntegrationKeyConfig) (chan keydata.KeyEvent, error)
  • func (l *LocalIntegration) ProcessStatsData(_ *utils.CMap[statsdata.StatsKey, statsdata.StatsData]) error
  • func (l *LocalIntegration) Type() IntegrationType

Variables

var (
	ErrStatsDataCorrupted = errors.New("stats data corrupted")
)

Types

type DrpcIntegrationClient

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

func NewDrpcIntegrationClient

func NewDrpcIntegrationClient(
	drpcIntegration *config.DrpcIntegrationConfig,
) *DrpcIntegrationClient

func NewDrpcIntegrationClientWithConnector

func NewDrpcIntegrationClientWithConnector(ctx context.Context, connector drpc.DrpcHttpConnector, pollInterval time.Duration) *DrpcIntegrationClient

func (*DrpcIntegrationClient) GetStatsSchema

func (d *DrpcIntegrationClient) GetStatsSchema() []statsdata.StatsDims

func (*DrpcIntegrationClient) InitKeys

func (d *DrpcIntegrationClient) InitKeys(_ string, cfg config.IntegrationKeyConfig) (chan keydata.KeyEvent, error)

func (*DrpcIntegrationClient) ProcessStatsData

func (d *DrpcIntegrationClient) ProcessStatsData(statsMap statsData) error

func (*DrpcIntegrationClient) Type

func (d *DrpcIntegrationClient) Type() IntegrationType

type DrpcOwnedKey

type DrpcOwnedKey struct {
	OwnerID  string
	ApiToken string
	ApiKey   string
}

type IntegrationClient

type IntegrationClient interface {
	InitKeys(id string, cfg config.IntegrationKeyConfig) (chan keydata.KeyEvent, error)
	GetStatsSchema() []statsdata.StatsDims
	ProcessStatsData(aggregatedData *utils.CMap[statsdata.StatsKey, statsdata.StatsData]) error
	Type() IntegrationType
}

type IntegrationResolver

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

func NewIntegrationResolver

func NewIntegrationResolver(cfg *config.IntegrationConfig) *IntegrationResolver

func NewNewIntegrationResolverWithClients

func NewNewIntegrationResolverWithClients(clients map[IntegrationType]IntegrationClient) *IntegrationResolver

func (*IntegrationResolver) GetIntegration

func (i *IntegrationResolver) GetIntegration(integrationType IntegrationType) IntegrationClient

type IntegrationType

type IntegrationType string

const (
	Drpc  IntegrationType = "drpc"
	Local IntegrationType = "local"
)

func GetIntegrationType

func GetIntegrationType(configType config.IntegrationType) IntegrationType

type LocalIntegration

type LocalIntegration struct {
}

func NewLocalIntegration

func NewLocalIntegration() *LocalIntegration

func (*LocalIntegration) GetStatsSchema

func (l *LocalIntegration) GetStatsSchema() []statsdata.StatsDims

func (*LocalIntegration) InitKeys

func (l *LocalIntegration) InitKeys(id string, cfg config.IntegrationKeyConfig) (chan keydata.KeyEvent, error)

func (*LocalIntegration) ProcessStatsData

func (l *LocalIntegration) ProcessStatsData(_ *utils.CMap[statsdata.StatsKey, statsdata.StatsData]) error

func (*LocalIntegration) Type

func (l *LocalIntegration) Type() IntegrationType