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 

func (m *MockBackendConfig) EXPECT() *MockBackendConfigMockRecorder

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 

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

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 

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

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 

func (m *MockworkspaceConfig) EXPECT() *MockworkspaceConfigMockRecorder

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 

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

Identity indicates an expected call of Identity.

func (*MockworkspaceConfigMockRecorder) SetUp 

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

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
}

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.