backendconfig

package
v1.4.3 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2022 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 added in v0.1.10 

func GetConfigBackendURL() string

func Init added in v0.1.10 

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 added in v0.1.10 

type ConfigT struct {
	EnableMetrics   bool            `json:"enableMetrics"`
	WorkspaceID     string          `json:"workspaceId"`
	Sources         []SourceT       `json:"sources"`
	Libraries       LibrariesT      `json:"libraries"`
	ConnectionFlags ConnectionFlags `json:"flags"`
	Settings        Settings        `json:"settings"`
}

type ConnectionFlags added in v0.1.10 

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

type DataRetention added in v1.3.0 

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

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 added in v0.1.10 

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 added in v0.1.10 

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

type LibrariesT added in v0.1.10 

type LibrariesT []LibraryT

type LibraryT added in v0.1.10 

type LibraryT struct {
	VersionID string
}

type MockBackendConfig added in v1.0.2 

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

MockBackendConfig is a mock of BackendConfig interface.

func NewMockBackendConfig added in v1.0.2 

func NewMockBackendConfig(ctrl *gomock.Controller) *MockBackendConfig

NewMockBackendConfig creates a new mock instance.

func (*MockBackendConfig) AccessToken added in v1.0.2 

func (m *MockBackendConfig) AccessToken() string

AccessToken mocks base method.

func (*MockBackendConfig) EXPECT added in v1.0.2 

func (m *MockBackendConfig) EXPECT() *MockBackendConfigMockRecorder

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

func (*MockBackendConfig) Get added in v1.0.2 

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

Get mocks base method.

func (*MockBackendConfig) Identity added in v1.2.0 

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

Identity mocks base method.

func (*MockBackendConfig) SetUp added in v1.0.2 

func (m *MockBackendConfig) SetUp() error

SetUp mocks base method.

func (*MockBackendConfig) StartWithIDs added in v1.0.2 

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

StartWithIDs mocks base method.

func (*MockBackendConfig) Stop added in v1.0.2 

func (m *MockBackendConfig) Stop()

Stop mocks base method.

func (*MockBackendConfig) Subscribe added in v1.0.2 

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

Subscribe mocks base method.

func (*MockBackendConfig) WaitForConfig added in v1.0.2 

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

WaitForConfig mocks base method.

type MockBackendConfigMockRecorder added in v1.0.2 

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

MockBackendConfigMockRecorder is the mock recorder for MockBackendConfig.

func (*MockBackendConfigMockRecorder) AccessToken added in v1.0.2 

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

AccessToken indicates an expected call of AccessToken.

func (*MockBackendConfigMockRecorder) Get added in v1.0.2 

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

Get indicates an expected call of Get.

func (*MockBackendConfigMockRecorder) Identity added in v1.2.0 

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

Identity indicates an expected call of Identity.

func (*MockBackendConfigMockRecorder) SetUp added in v1.0.2 

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

SetUp indicates an expected call of SetUp.

func (*MockBackendConfigMockRecorder) StartWithIDs added in v1.0.2 

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

StartWithIDs indicates an expected call of StartWithIDs.

func (*MockBackendConfigMockRecorder) Stop added in v1.0.2 

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

Stop indicates an expected call of Stop.

func (*MockBackendConfigMockRecorder) Subscribe added in v1.0.2 

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

Subscribe indicates an expected call of Subscribe.

func (*MockBackendConfigMockRecorder) WaitForConfig added in v1.0.2 

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

WaitForConfig indicates an expected call of WaitForConfig.

type MockworkspaceConfig added in v1.0.2 

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

MockworkspaceConfig is a mock of workspaceConfig interface.

func NewMockworkspaceConfig added in v1.0.2 

func NewMockworkspaceConfig(ctrl *gomock.Controller) *MockworkspaceConfig

NewMockworkspaceConfig creates a new mock instance.

func (*MockworkspaceConfig) AccessToken added in v1.0.2 

func (m *MockworkspaceConfig) AccessToken() string

AccessToken mocks base method.

func (*MockworkspaceConfig) EXPECT added in v1.0.2 

func (m *MockworkspaceConfig) EXPECT() *MockworkspaceConfigMockRecorder

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

func (*MockworkspaceConfig) Get added in v1.0.2 

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

Get mocks base method.

func (*MockworkspaceConfig) Identity added in v1.2.0 

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

Identity mocks base method.

func (*MockworkspaceConfig) SetUp added in v1.0.2 

func (m *MockworkspaceConfig) SetUp() error

SetUp mocks base method.

type MockworkspaceConfigMockRecorder added in v1.0.2 

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

MockworkspaceConfigMockRecorder is the mock recorder for MockworkspaceConfig.

func (*MockworkspaceConfigMockRecorder) AccessToken added in v1.0.2 

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

AccessToken indicates an expected call of AccessToken.

func (*MockworkspaceConfigMockRecorder) Get added in v1.0.2 

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

Get indicates an expected call of Get.

func (*MockworkspaceConfigMockRecorder) Identity added in v1.2.0 

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

Identity indicates an expected call of Identity.

func (*MockworkspaceConfigMockRecorder) SetUp added in v1.0.2 

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

SetUp indicates an expected call of SetUp.

type NOOP added in v1.2.0 

type NOOP struct{}

func (*NOOP) AccessToken added in v1.2.0 

func (*NOOP) AccessToken() string

func (*NOOP) Get added in v1.2.0 

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

func (*NOOP) Identity added in v1.2.0 

func (*NOOP) Identity() identity.Identifier

func (*NOOP) SetUp added in v1.2.0 

func (*NOOP) SetUp() error

func (*NOOP) StartWithIDs added in v1.2.0 

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

func (*NOOP) Stop added in v1.2.0 

func (*NOOP) Stop()

func (*NOOP) Subscribe added in v1.2.0 

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

func (*NOOP) WaitForConfig added in v1.2.0 

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

type Regulation added in v0.1.10 

type Regulation string

type SRegulationsT added in v0.1.10 

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 added in v1.3.0 

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

type SourceDefinitionT 

type SourceDefinitionT struct {
	ID       string
	Name     string
	Category string
}

type SourceRegulationT added in v0.1.10 

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

type SourceT 

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

type StorageBucket added in v1.3.0 

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

type StoragePreferences added in v1.3.0 

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 added in v1.3.0 

func (sp StoragePreferences) Backup(tableprefix string) bool

type Topic added in v0.1.10 

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 added in v0.1.10 

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 added in v0.1.10 

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 added in v0.1.10 

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.