backendconfig

package
v0.0.0-...-0ade494 Latest Latest
Warning

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

 Go to latest Published: Aug 26, 2022 License: AGPL-3.0 Imports: 25 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"`
	Libraries       LibrariesT      `json:"libraries"`
	ConnectionFlags ConnectionFlags `json:"flags"`
}

type ConnectionFlags 

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

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
	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 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, arg1 string) (ConfigT, error)

Get mocks base method.

func (*MockBackendConfig) GetWorkspaceIDForSourceID 

func (m *MockBackendConfig) GetWorkspaceIDForSourceID(arg0 string) string

GetWorkspaceIDForSourceID mocks base method.

func (*MockBackendConfig) GetWorkspaceIDForWriteKey 

func (m *MockBackendConfig) GetWorkspaceIDForWriteKey(arg0 string) string

GetWorkspaceIDForWriteKey mocks base method.

func (*MockBackendConfig) GetWorkspaceLibrariesForWorkspaceID 

func (m *MockBackendConfig) GetWorkspaceLibrariesForWorkspaceID(arg0 string) LibrariesT

GetWorkspaceLibrariesForWorkspaceID 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, arg1 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockBackendConfigMockRecorder) GetWorkspaceIDForSourceID 

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

GetWorkspaceIDForSourceID indicates an expected call of GetWorkspaceIDForSourceID.

func (*MockBackendConfigMockRecorder) GetWorkspaceIDForWriteKey 

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

GetWorkspaceIDForWriteKey indicates an expected call of GetWorkspaceIDForWriteKey.

func (*MockBackendConfigMockRecorder) GetWorkspaceLibrariesForWorkspaceID 

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

GetWorkspaceLibrariesForWorkspaceID indicates an expected call of GetWorkspaceLibrariesForWorkspaceID.

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, arg1 string) (ConfigT, error)

Get mocks base method.

func (*MockworkspaceConfig) GetWorkspaceIDForSourceID 

func (m *MockworkspaceConfig) GetWorkspaceIDForSourceID(arg0 string) string

GetWorkspaceIDForSourceID mocks base method.

func (*MockworkspaceConfig) GetWorkspaceIDForWriteKey 

func (m *MockworkspaceConfig) GetWorkspaceIDForWriteKey(arg0 string) string

GetWorkspaceIDForWriteKey mocks base method.

func (*MockworkspaceConfig) GetWorkspaceLibrariesForWorkspaceID 

func (m *MockworkspaceConfig) GetWorkspaceLibrariesForWorkspaceID(arg0 string) LibrariesT

GetWorkspaceLibrariesForWorkspaceID 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, arg1 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockworkspaceConfigMockRecorder) GetWorkspaceIDForSourceID 

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

GetWorkspaceIDForSourceID indicates an expected call of GetWorkspaceIDForSourceID.

func (*MockworkspaceConfigMockRecorder) GetWorkspaceIDForWriteKey 

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

GetWorkspaceIDForWriteKey indicates an expected call of GetWorkspaceIDForWriteKey.

func (*MockworkspaceConfigMockRecorder) GetWorkspaceLibrariesForWorkspaceID 

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

GetWorkspaceLibrariesForWorkspaceID indicates an expected call of GetWorkspaceLibrariesForWorkspaceID.

func (*MockworkspaceConfigMockRecorder) SetUp 

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

SetUp indicates an expected call of SetUp.

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 SourceDefinitionT 

type SourceDefinitionT struct {
	ID       string
	Name     string
	Category string
}

type SourceRegulationT 

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 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
}

type WorkspacesT 

type WorkspacesT struct {
	WorkspaceSourcesMap map[string]ConfigT `json:"-"`
}

WorkspacesT holds sources of workspaces

Source Files

View all Source files

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.