datastore

Documentation

Index

• Constants
• type AWSXRayConfig
• type AzureAppInsightsConfig
• type ConnectionTypes
• type DataStore
  • func (ds DataStore) GetID() id.ID
  • func (ds DataStore) HasID() bool
  • func (ds DataStore) IsOTLPBasedProvider() bool
  • func (d DataStore) MarshalJSON() ([]byte, error)
  • func (d DataStore) MarshalYAML() ([]byte, error)
  • func (d *DataStore) UnmarshalJSON(input []byte) error
  • func (d *DataStore) UnmarshalYAML(input []byte) error
  • func (ds DataStore) Validate() error
• type DataStoreType
• type DataStoreValues
• type ElasticSearchConfig
• type GRPCClientSettings
• type GRPCCompression
• type HttpClientConfig
• type MultiChannelClientConfig
• type MultiChannelClientType
• type Repository
  • func NewRepository(db *sql.DB) *Repository
  • func (r *Repository) Count(ctx context.Context, query string) (int, error)
  • func (r *Repository) Create(ctx context.Context, updated DataStore) (DataStore, error)
  • func (r *Repository) Current(ctx context.Context) (DataStore, error)
  • func (r *Repository) Get(ctx context.Context, id id.ID) (DataStore, error)
  • func (r *Repository) List(ctx context.Context, take, skip int, query, sortBy, sortDirection string) ([]DataStore, error)
  • func (r *Repository) Provision(ctx context.Context, dataStore DataStore) error
  • func (r *Repository) SetID(dataStore DataStore, id id.ID) DataStore
  • func (*Repository) SortingFields() []string
  • func (r *Repository) Update(ctx context.Context, dataStore DataStore) (DataStore, error)
• type SignalFXConfig
• type SumoLogicConfig
• type TLS
• type TLSSetting

Constants

const DataStoreSingleID id.ID = "current"

const ResourceName = "DataStore"

const ResourceNamePlural = "DataStores"

Types

type AWSXRayConfig

type AWSXRayConfig struct {
	Region          string `json:"region"`
	AccessKeyID     string `json:"accessKeyId"`
	SecretAccessKey string `json:"secretAccessKey"`
	SessionToken    string `json:"sessionToken"`
	UseDefaultAuth  bool   `json:"useDefaultAuth"`
}

type AzureAppInsightsConfig

type AzureAppInsightsConfig struct {
	UseAzureActiveDirectoryAuth bool            `json:"useAzureActiveDirectoryAuth"`
	AccessToken                 string          `json:"accessToken"`
	ResourceArmId               string          `json:"resourceArmId"`
	ConnectionType              ConnectionTypes `json:"connectionType"`
}

type ConnectionTypes

type ConnectionTypes string

const (
	ConnectionTypesDirect    ConnectionTypes = "direct"
	ConnectionTypesCollector ConnectionTypes = "collector"
)

type DataStore

type DataStore struct {
	ID        id.ID           `json:"id"`
	Name      string          `json:"name"`
	Type      DataStoreType   `json:"type"`
	Default   bool            `json:"default"`
	Values    DataStoreValues `json:"values"`
	CreatedAt string          `json:"createdAt"`
}

func (DataStore) GetID

func (ds DataStore) GetID() id.ID

func (DataStore) HasID

func (ds DataStore) HasID() bool

func (DataStore) IsOTLPBasedProvider

func (ds DataStore) IsOTLPBasedProvider() bool

func (DataStore) MarshalJSON

func (d DataStore) MarshalJSON() ([]byte, error)

func (DataStore) MarshalYAML

func (d DataStore) MarshalYAML() ([]byte, error)

func (*DataStore) UnmarshalJSON

func (d *DataStore) UnmarshalJSON(input []byte) error

func (*DataStore) UnmarshalYAML

func (d *DataStore) UnmarshalYAML(input []byte) error

func (DataStore) Validate

func (ds DataStore) Validate() error

type DataStoreType

type DataStoreType string

const (
	DataStoreTypeAgent            DataStoreType = "agent"
	DataStoreTypeAwsXRay          DataStoreType = "awsxray"
	DataStoreTypeAzureAppInsights DataStoreType = "azureappinsights"
	DataStoreTypeDataDog          DataStoreType = "datadog"
	DataStoreTypeDynatrace        DataStoreType = "dynatrace"
	DataStoreTypeElasticAPM       DataStoreType = "elasticapm"
	DataStoreTypeHoneycomb        DataStoreType = "honeycomb"
	DataStoreTypeInstana          DataStoreType = "instana"
	DataStoreTypeJaeger           DataStoreType = "jaeger"
	DataStoreTypeLighStep         DataStoreType = "lightstep"
	DataStoreTypeNewRelic         DataStoreType = "newrelic"
	DataStoreTypeOpenSearch       DataStoreType = "opensearch"
	DataStoreTypeOTLP             DataStoreType = "otlp"
	DataStoreTypeSignalFX         DataStoreType = "signalfx"
	DataStoreTypeSignoz           DataStoreType = "signoz"
	DataStoreTypeSumoLogic        DataStoreType = "sumologic"
	DataStoreTypeTempo            DataStoreType = "tempo"
)

type DataStoreValues

type DataStoreValues struct {
	AwsXRay          *AWSXRayConfig            `json:"awsxray,omitempty"`
	ElasticApm       *ElasticSearchConfig      `json:"elasticapm,omitempty"`
	Jaeger           *GRPCClientSettings       `json:"jaeger,omitempty"`
	OpenSearch       *ElasticSearchConfig      `json:"opensearch,omitempty"`
	SignalFx         *SignalFXConfig           `json:"signalfx,omitempty"`
	Tempo            *MultiChannelClientConfig `json:"tempo,omitempty"`
	AzureAppInsights *AzureAppInsightsConfig   `json:"azureappinsights,omitempty"`
	SumoLogic        *SumoLogicConfig          `json:"sumologic"`
}

type ElasticSearchConfig

type ElasticSearchConfig struct {
	Addresses          []string `json:"addresses"`
	Username           string   `json:"username"`
	Password           string   `json:"password"`
	Index              string   `json:"index"`
	Certificate        string   `json:"certificate"`
	InsecureSkipVerify bool     `json:"insecureSkipVerify"`
}

type GRPCClientSettings

type GRPCClientSettings struct {
	Endpoint        string            `json:"endpoint,omitempty"`
	ReadBufferSize  int               `json:"readBufferSize,omitempty"`
	WriteBufferSize int               `json:"writeBufferSize,omitempty"`
	WaitForReady    bool              `json:"waitForReady,omitempty"`
	Headers         map[string]string `json:"headers,omitempty"`
	BalancerName    string            `json:"balancerName,omitempty"`
	Compression     GRPCCompression   `json:"compression,omitempty"`
	TLS             *TLS              `json:"tls,omitempty"`
}

type GRPCCompression

type GRPCCompression string

const (
	GRPCCompressionGZip    GRPCCompression = "gzip"
	GRPCCompressionZlib    GRPCCompression = "zlib"
	GRPCCompressionDeflate GRPCCompression = "deflate"
	GRPCCompressionSnappy  GRPCCompression = "snappy"
	GRPCCompressionZstd    GRPCCompression = "zstd"
	GRPCCompressionNone    GRPCCompression = "none"
)

type HttpClientConfig

type HttpClientConfig struct {
	Url     string            `json:"url"`
	Headers map[string]string `json:"headers,omitempty"`
	TLS     *TLS              `json:"tls,omitempty"`
}

type MultiChannelClientConfig

type MultiChannelClientConfig struct {
	Type MultiChannelClientType `json:"type"`
	Grpc *GRPCClientSettings    `json:"grpc,omitempty"`
	Http *HttpClientConfig      `json:"http,omitempty"`
}

type MultiChannelClientType

type MultiChannelClientType string

const (
	MultiChannelClientTypeGRPC MultiChannelClientType = "grpc"
	MultiChannelClientTypeHTTP MultiChannelClientType = "http"
)

type Repository

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

func NewRepository

func NewRepository(db *sql.DB) *Repository

func (*Repository) Count

func (r *Repository) Count(ctx context.Context, query string) (int, error)

func (*Repository) Create

func (r *Repository) Create(ctx context.Context, updated DataStore) (DataStore, error)

func (*Repository) Current

func (r *Repository) Current(ctx context.Context) (DataStore, error)

func (*Repository) Get

func (r *Repository) Get(ctx context.Context, id id.ID) (DataStore, error)

func (*Repository) List

func (r *Repository) List(ctx context.Context, take, skip int, query, sortBy, sortDirection string) ([]DataStore, error)

func (*Repository) Provision

func (r *Repository) Provision(ctx context.Context, dataStore DataStore) error

func (*Repository) SetID

func (r *Repository) SetID(dataStore DataStore, id id.ID) DataStore

func (*Repository) SortingFields

func (*Repository) SortingFields() []string

func (*Repository) Update

func (r *Repository) Update(ctx context.Context, dataStore DataStore) (DataStore, error)

type SignalFXConfig

type SignalFXConfig struct {
	Realm string `json:"realm"`
	Token string `json:"token"`
}

type SumoLogicConfig

type SumoLogicConfig struct {
	URL       string `json:"url"`
	AccessID  string `json:"accessID"`
	AccessKey string `json:"accessKey"`
}

type TLS

type TLS struct {
	Insecure           bool        `json:"insecure,omitempty"`
	InsecureSkipVerify bool        `json:"insecureSkipVerify,omitempty"`
	ServerName         string      `json:"serverName,omitempty"`
	Settings           *TLSSetting `json:"settings,omitempty"`
}

type TLSSetting

type TLSSetting struct {
	CAFile     string `json:"cAFile,omitempty"`
	CertFile   string `json:"certFile,omitempty"`
	KeyFile    string `json:"keyFile,omitempty"`
	MinVersion string `json:"minVersion,omitempty"`
	MaxVersion string `json:"maxVersion,omitempty"`
}