settings

Documentation

Index

• type AuthenticationSettings
  • func NewAuthenticationSettings(keyId string, keySecret string) *AuthenticationSettings
  • func (s *AuthenticationSettings) GetBody() map[string]string
  • func (s *AuthenticationSettings) IsEmpty() bool
• type ExternalStorageSettings
  • func NewExternalStorageSettings(taskOutputPayloadThresholdKB int64, taskOutputMaxPayloadThresholdKB int64, ...) *ExternalStorageSettings
• type HttpSettings
  • func NewHttpDefaultSettings() *HttpSettings
  • func NewHttpSettings(baseUrl string) *HttpSettings
• type MetricsSettings
  • func NewDefaultMetricsSettings() *MetricsSettings
  • func NewMetricsSettings(apiEndpoint string, port int) *MetricsSettings

Types

type AuthenticationSettings

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

func NewAuthenticationSettings

func NewAuthenticationSettings(keyId string, keySecret string) *AuthenticationSettings

func (*AuthenticationSettings) GetBody

func (s *AuthenticationSettings) GetBody() map[string]string

func (*AuthenticationSettings) IsEmpty

func (s *AuthenticationSettings) IsEmpty() bool

type ExternalStorageSettings

type ExternalStorageSettings struct {
	TaskOutputPayloadThresholdKB    int64
	TaskOutputMaxPayloadThresholdKB int64
	ExternalStorageHandler          model.ExternalStorageHandler
}

func NewExternalStorageSettings

func NewExternalStorageSettings(
	taskOutputPayloadThresholdKB int64,
	taskOutputMaxPayloadThresholdKB int64,
	externalStorageHandler model.ExternalStorageHandler,
) *ExternalStorageSettings

type HttpSettings

type HttpSettings struct {
	BaseUrl string
	Headers map[string]string
}

func NewHttpDefaultSettings

func NewHttpDefaultSettings() *HttpSettings

func NewHttpSettings

func NewHttpSettings(baseUrl string) *HttpSettings

type MetricsSettings

type MetricsSettings struct {
	ApiEndpoint string
	Port        int
}

MetricsSettings configures the prometheus metrics for worker SDK

func NewDefaultMetricsSettings

func NewDefaultMetricsSettings() *MetricsSettings

NewDefaultMetricsSettings creates an endpoint at /metrics on port 2112

func NewMetricsSettings

func NewMetricsSettings(apiEndpoint string, port int) *MetricsSettings

NewMetricsSettings new metrics settings with endpoint and port