backendconfig

package
v1.13.0-rc.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 29, 2023 License: AGPL-3.0 Imports: 29 Imported by: 0

Documentation

Overview

Package backendconfig is a generated GoMock package.

Index

Constants

View Source
const (
	/*TopicBackendConfig topic provides updates on full backend config, via Subscribe function */
	TopicBackendConfig Topic = "backendConfig"

	/*TopicProcessConfig topic provides updates on backend config of processor enabled destinations, via Subscribe function */
	TopicProcessConfig Topic = "processConfig"

	/*RegulationSuppress refers to Suppress Regulation */
	RegulationSuppress Regulation = "Suppress"

	/*RegulationDelete refers to Suppress and Delete Regulation */
	RegulationDelete Regulation = "Delete" // TODO Will add support soon.

	/*RegulationSuppressAndDelete refers to Suppress and Delete Regulation */
	RegulationSuppressAndDelete Regulation = "Suppress_With_Delete"

	GlobalEventType = "global"
)

Variables

View Source
var (
	LastSync           string
	LastRegulationSync string

	// DefaultBackendConfig will be initialized be Setup to either a WorkspaceConfig or MultiWorkspaceConfig.
	DefaultBackendConfig BackendConfig

	IoUtil      = sysUtils.NewIoUtil()
	Diagnostics diagnostics.DiagnosticsI
)

Functions

func GetConfigBackendURL

func GetConfigBackendURL() string

func Init

func Init()

func Setup

func Setup(configEnvHandler types.ConfigEnvI) (err error)

Setup backend config

Types

type BackendConfig

type BackendConfig interface {
	WaitForConfig(ctx context.Context)
	Subscribe(ctx context.Context, topic Topic) pubsub.DataChannel
	Stop()
	StartWithIDs(ctx context.Context, workspaces string)
	// contains filtered or unexported methods
}

type ConfigT

type ConfigT struct {
	EnableMetrics   bool                         `json:"enableMetrics"`
	WorkspaceID     string                       `json:"workspaceId"`
	Sources         []SourceT                    `json:"sources"`
	EventReplays    map[string]EventReplayConfig `json:"eventReplays"`
	Libraries       LibrariesT                   `json:"libraries"`
	ConnectionFlags ConnectionFlags              `json:"flags"`
	Settings        Settings                     `json:"settings"`
	UpdatedAt       time.Time                    `json:"updatedAt"`
}

func (*ConfigT) ApplyReplaySources added in v1.12.0

func (config *ConfigT) ApplyReplaySources()

ApplyReplaySources reads the event replay configuration and adds replay sources to the config A replay source is a copy of the original source with a different ID and source definition This replay source contains as destinations replay destinations which are copies of the original destinations but with a different ID

func (*ConfigT) DestinationsMap added in v1.12.0

func (c *ConfigT) DestinationsMap() map[string]*DestinationT

func (*ConfigT) SourcesMap added in v1.12.0

func (c *ConfigT) SourcesMap() map[string]*SourceT

type ConnectionFlags

type ConnectionFlags struct {
	URL      string          `json:"url"`
	Services map[string]bool `json:"services"`
}

type DataRetention

type DataRetention struct {
	DisableReportingPII bool               `json:"disableReportingPii"`
	UseSelfStorage      bool               `json:"useSelfStorage"`
	StorageBucket       StorageBucket      `json:"storageBucket"`
	StoragePreferences  StoragePreferences `json:"storagePreferences"`
	RetentionPeriod     string             `json:"retentionPeriod"`
}

type DestinationDefinitionT

type DestinationDefinitionT struct {
	ID            string
	Name          string
	DisplayName   string
	Config        map[string]interface{}
	ResponseRules map[string]interface{}
}

type DestinationT

type DestinationT struct {
	ID                    string
	Name                  string
	DestinationDefinition DestinationDefinitionT
	Config                map[string]interface{}
	Enabled               bool
	WorkspaceID           string
	Transformations       []TransformationT
	IsProcessorEnabled    bool
	RevisionID            string
}

type DgSourceTrackingPlanConfigT

type DgSourceTrackingPlanConfigT struct {
	SourceId            string                            `json:"sourceId"`
	SourceConfigVersion int                               `json:"version"`
	Config              map[string]map[string]interface{} `json:"config"`
	MergedConfig        map[string]interface{}            `json:"mergedConfig"`
	Deleted             bool                              `json:"deleted"`
	TrackingPlan        TrackingPlanT                     `json:"trackingPlan"`
}

func (*DgSourceTrackingPlanConfigT) GetMergedConfig

func (dgSourceTPConfigT *DgSourceTrackingPlanConfigT) GetMergedConfig(eventType string) map[string]interface{}

type EventReplayConfig added in v1.12.0

type EventReplayConfig struct {
	Sources      map[string]EventReplaySource      `json:"sources"`
	Destinations map[string]EventReplayDestination `json:"destinations"`
	Connections  []EventReplayConnection           `json:"connections"`
}

type EventReplayConfigs added in v1.12.0

type EventReplayConfigs map[string]*EventReplayConfig

type EventReplayConnection added in v1.12.0

type EventReplayConnection struct {
	SourceID      string `json:"sourceId"`
	DestinationID string `json:"destinationId"`
}

type EventReplayDestination added in v1.12.0

type EventReplayDestination struct {
	OriginalDestinationID string `json:"originalId"`
}

type EventReplaySource added in v1.12.0

type EventReplaySource struct {
	OriginalSourceID string `json:"originalId"`
}

type LibrariesT

type LibrariesT []LibraryT

type LibraryT

type LibraryT struct {
	VersionID string
}

type MockBackendConfig

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

MockBackendConfig is a mock of BackendConfig interface.

func NewMockBackendConfig

func NewMockBackendConfig(ctrl *gomock.Controller) *MockBackendConfig

NewMockBackendConfig creates a new mock instance.

func (*MockBackendConfig) AccessToken

func (m *MockBackendConfig) AccessToken() string

AccessToken mocks base method.

func (*MockBackendConfig) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBackendConfig) Get

func (m *MockBackendConfig) Get(arg0 context.Context) (map[string]ConfigT, error)

Get mocks base method.

func (*MockBackendConfig) Identity

func (m *MockBackendConfig) Identity() identity.Identifier

Identity mocks base method.

func (*MockBackendConfig) SetUp

func (m *MockBackendConfig) SetUp() error

SetUp mocks base method.

func (*MockBackendConfig) StartWithIDs

func (m *MockBackendConfig) StartWithIDs(ctx context.Context, workspaces string)

StartWithIDs mocks base method.

func (*MockBackendConfig) Stop

func (m *MockBackendConfig) Stop()

Stop mocks base method.

func (*MockBackendConfig) Subscribe

func (m *MockBackendConfig) Subscribe(ctx context.Context, topic Topic) pubsub.DataChannel

Subscribe mocks base method.

func (*MockBackendConfig) WaitForConfig

func (m *MockBackendConfig) WaitForConfig(ctx context.Context)

WaitForConfig mocks base method.

type MockBackendConfigMockRecorder

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

MockBackendConfigMockRecorder is the mock recorder for MockBackendConfig.

func (*MockBackendConfigMockRecorder) AccessToken

func (mr *MockBackendConfigMockRecorder) AccessToken() *gomock.Call

AccessToken indicates an expected call of AccessToken.

func (*MockBackendConfigMockRecorder) Get

func (mr *MockBackendConfigMockRecorder) Get(arg0 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockBackendConfigMockRecorder) Identity

func (mr *MockBackendConfigMockRecorder) Identity() *gomock.Call

Identity indicates an expected call of Identity.

func (*MockBackendConfigMockRecorder) SetUp

SetUp indicates an expected call of SetUp.

func (*MockBackendConfigMockRecorder) StartWithIDs

func (mr *MockBackendConfigMockRecorder) StartWithIDs(ctx, workspaces interface{}) *gomock.Call

StartWithIDs indicates an expected call of StartWithIDs.

func (*MockBackendConfigMockRecorder) Stop

Stop indicates an expected call of Stop.

func (*MockBackendConfigMockRecorder) Subscribe

func (mr *MockBackendConfigMockRecorder) Subscribe(ctx, topic interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockBackendConfigMockRecorder) WaitForConfig

func (mr *MockBackendConfigMockRecorder) WaitForConfig(ctx interface{}) *gomock.Call

WaitForConfig indicates an expected call of WaitForConfig.

type MockworkspaceConfig

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

MockworkspaceConfig is a mock of workspaceConfig interface.

func NewMockworkspaceConfig

func NewMockworkspaceConfig(ctrl *gomock.Controller) *MockworkspaceConfig

NewMockworkspaceConfig creates a new mock instance.

func (*MockworkspaceConfig) AccessToken

func (m *MockworkspaceConfig) AccessToken() string

AccessToken mocks base method.

func (*MockworkspaceConfig) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockworkspaceConfig) Get

func (m *MockworkspaceConfig) Get(arg0 context.Context) (map[string]ConfigT, error)

Get mocks base method.

func (*MockworkspaceConfig) Identity

func (m *MockworkspaceConfig) Identity() identity.Identifier

Identity mocks base method.

func (*MockworkspaceConfig) SetUp

func (m *MockworkspaceConfig) SetUp() error

SetUp mocks base method.

type MockworkspaceConfigMockRecorder

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

MockworkspaceConfigMockRecorder is the mock recorder for MockworkspaceConfig.

func (*MockworkspaceConfigMockRecorder) AccessToken

func (mr *MockworkspaceConfigMockRecorder) AccessToken() *gomock.Call

AccessToken indicates an expected call of AccessToken.

func (*MockworkspaceConfigMockRecorder) Get

func (mr *MockworkspaceConfigMockRecorder) Get(arg0 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockworkspaceConfigMockRecorder) Identity

Identity indicates an expected call of Identity.

func (*MockworkspaceConfigMockRecorder) SetUp

SetUp indicates an expected call of SetUp.

type NOOP

type NOOP struct{}

func (*NOOP) AccessToken

func (*NOOP) AccessToken() string

func (*NOOP) Get

func (*NOOP) Get(_ context.Context) (map[string]ConfigT, error)

func (*NOOP) Identity

func (*NOOP) Identity() identity.Identifier

func (*NOOP) SetUp

func (*NOOP) SetUp() error

func (*NOOP) StartWithIDs

func (*NOOP) StartWithIDs(_ context.Context, _ string)

func (*NOOP) Stop

func (*NOOP) Stop()

func (*NOOP) Subscribe

func (*NOOP) Subscribe(ctx context.Context, _ Topic) pubsub.DataChannel

func (*NOOP) WaitForConfig

func (*NOOP) WaitForConfig(_ context.Context)

type Regulation

type Regulation string

type SRegulationsT

type SRegulationsT struct {
	SourceRegulations []SourceRegulationT `json:"sourceRegulations"`
	Start             int                 `json:"start"`
	Limit             int                 `json:"limit"`
	Size              int                 `json:"size"`
	End               bool                `json:"end"`
	Next              int                 `json:"next"`
}

type Settings

type Settings struct {
	DataRetention DataRetention `json:"dataRetention"`
}

type SourceDefinitionT

type SourceDefinitionT struct {
	ID       string
	Name     string
	Category string
	Type     string // // Indicates whether source is one of {cloud, web, flutter, android, ios, warehouse, cordova, amp, reactnative, unity}. This field is not present in sources table
}

type SourceRegulationT

type SourceRegulationT struct {
	ID             string
	RegulationType string
	WorkspaceID    string
	SourceID       string
	UserID         string
}

type SourceT

type SourceT struct {
	ID                         string
	OriginalID                 string
	Name                       string
	SourceDefinition           SourceDefinitionT
	Config                     map[string]interface{}
	Enabled                    bool
	WorkspaceID                string
	Destinations               []DestinationT
	WriteKey                   string
	DgSourceTrackingPlanConfig DgSourceTrackingPlanConfigT
	Transient                  bool
	EventSchemasEnabled        bool
}

func (*SourceT) IsReplaySource

func (s *SourceT) IsReplaySource() bool

type StorageBucket

type StorageBucket struct {
	Type   string `json:"type"`
	Config map[string]interface{}
}

type StoragePreferences

type StoragePreferences struct {
	ProcErrors       bool `json:"procErrors"`
	GatewayDumps     bool `json:"gatewayDumps"`
	ProcErrorDumps   bool `json:"procErrorDumps"`
	RouterDumps      bool `json:"routerDumps"`
	BatchRouterDumps bool `json:"batchRouterDumps"`
}

func (StoragePreferences) Backup

func (sp StoragePreferences) Backup(tableprefix string) bool

type Topic

type Topic string

Topic refers to a subset of backend config's updates, received after subscribing using the backend config's Subscribe function.

type TrackingPlanT

type TrackingPlanT struct {
	Id      string `json:"id"`
	Version int    `json:"version"`
}

type TransformationT

type TransformationT struct {
	VersionID string
	ID        string
	Config    map[string]interface{}
}

type WRegulationsT

type WRegulationsT struct {
	WorkspaceRegulations []WorkspaceRegulationT `json:"workspaceRegulations"`
	Start                int                    `json:"start"`
	Limit                int                    `json:"limit"`
	Size                 int                    `json:"size"`
	End                  bool                   `json:"end"`
	Next                 int                    `json:"next"`
}

type WorkspaceRegulationT

type WorkspaceRegulationT struct {
	ID             string
	RegulationType string
	WorkspaceID    string
	UserID         string
}

Directories

Path Synopsis
internal
cache
Package cache is a generated GoMock package.
Package cache is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL