client

Documentation

Index

• func New(ctx context.Context, logger zerolog.Logger, s specs.Source, ...) (schema.ClientMeta, error)
• func ProjectMultiplex(meta schema.ClientMeta) []schema.ClientMeta
• func ResolveProjectId(_ context.Context, meta schema.ClientMeta, r *schema.Resource, c schema.Column) error
• type Client
  • func (c *Client) ID() string
• type Spec
  • func (spec *Spec) Validate() error

Functions

func New

func New(ctx context.Context, logger zerolog.Logger, s specs.Source, opts source.Options) (schema.ClientMeta, error)

func ProjectMultiplex

func ProjectMultiplex(meta schema.ClientMeta) []schema.ClientMeta

func ResolveProjectId

func ResolveProjectId(_ context.Context, meta schema.ClientMeta, r *schema.Resource, c schema.Column) error

Types

type Client

type Client struct {
	Spec Spec

	SwetrixClient *rest.SwetrixRestClient

	// We multiplex based on projectId - this is the projectId this client is responsible for.
	ProjectId string

	Logger zerolog.Logger
}

func (*Client) ID

func (c *Client) ID() string

type Spec

type Spec struct {
	ProjectIds []string `json:"project_ids"`
	ApiKey     string   `json:"api_key"`

	TimeBucket string `json:"time_bucket"`
	Period     string `json:"period"`

	From     string `json:"from"`
	To       string `json:"to"`
	Timezone string `json:"timezone"`
}

func (*Spec) Validate

func (spec *Spec) Validate() error