backendconfig

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2023 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Eb *utils.EventBus
)
View Source 
var SourceStatus, DestinationStatus, DestAccessType map[string]string

Functions

func GetConnectionString 

func GetConnectionString() string

func Subscribe 

func Subscribe(channel chan utils.DataEvent)

Types

type ConnectionDetailT added in v1.1.0 

type ConnectionDetailT struct {
	Connection        ConnectionInstanceT `json:"connection"`
	SourceDetail      SourceDetailT       `json:"source_detail"`
	DestinationDetail DestinationDetailT  `json:"destination_detail"`
}

type ConnectionDetailsT added in v1.1.0 

type ConnectionDetailsT struct {
	Connections []ConnectionDetailT `json:"connections"`
}

func GetConfig 

func GetConfig() ConnectionDetailsT

type ConnectionInstanceT added in v1.1.0 

type ConnectionInstanceT struct {
	ID            int    `json:"id"`
	SourceID      int    `json:"source_id"`
	DestinationID int    `json:"destination_id"`
	Transforms    string `json:"transforms"`
}

type DestinationConnectionsT added in v1.1.0 

type DestinationConnectionsT struct {
	DestinationDetail DestinationDetailT `json:"destination_detail"`
	SourceDetails     []SourceDetailT    `json:"source_details`
}

type DestinationDefinitionT 

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

type DestinationDetailT added in v1.1.0 

type DestinationDetailT struct {
	Destination DestinationInstanceT `json:"destination"`
	Catalogue   ServiceCatalogueT    `json:"catalogue"`
}

type DestinationInstanceT added in v1.1.0 

type DestinationInstanceT struct {
	ID         int    `json:"id"`
	Name       string `json:"name"`
	ServiceID  int    `json:"service_id"`
	CustomerID int    `json:"customer_id"`
	Config     string `json:"config"`
	Status     string `json:"status"`
}

func (DestinationInstanceT) Disabled added in v1.1.0 

func (dest DestinationInstanceT) Disabled() bool

func (DestinationInstanceT) Enabled added in v1.1.0 

func (dest DestinationInstanceT) Enabled() bool

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

type HandleT 

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

func (*HandleT) Authenticate added in v1.1.0 

func (cd *HandleT) Authenticate(hashValue string) (bool, error)

func (*HandleT) CreateConnectionTable added in v1.1.0 

func (cd *HandleT) CreateConnectionTable()

func (*HandleT) CreateDestinationTable added in v1.1.0 

func (cd *HandleT) CreateDestinationTable()

func (*HandleT) CreateNewConnection added in v1.1.0 

func (cd *HandleT) CreateNewConnection(connection ConnectionInstanceT) bool

func (*HandleT) CreateNewDestination added in v1.1.0 

func (cd *HandleT) CreateNewDestination(destination DestinationInstanceT) bool

func (*HandleT) CreateNewServiceCatalogue added in v1.1.0 

func (cd *HandleT) CreateNewServiceCatalogue(catalogue ServiceCatalogueT) bool

func (*HandleT) CreateNewSource added in v1.1.0 

func (cd *HandleT) CreateNewSource(source SourceInstanceT) bool

func (*HandleT) CreateServiceCatalogueTable added in v1.1.0 

func (cd *HandleT) CreateServiceCatalogueTable()

func (*HandleT) CreateSourceTable added in v1.1.0 

func (cd *HandleT) CreateSourceTable()

func (*HandleT) DeleteConnection added in v1.1.0 

func (cd *HandleT) DeleteConnection(connectionID int) bool

func (*HandleT) DeleteDestination added in v1.1.0 

func (cd *HandleT) DeleteDestination(destinationID int) bool

func (*HandleT) DeleteServiceCatalogue added in v1.1.0 

func (cd *HandleT) DeleteServiceCatalogue(service_id string) bool

func (*HandleT) DeleteSource added in v1.1.0 

func (cd *HandleT) DeleteSource(sourceID int) bool

func (*HandleT) GetAllConnections added in v1.1.0 

func (cd *HandleT) GetAllConnections() []ConnectionDetailT

func (*HandleT) GetAllDestinations added in v1.1.0 

func (cd *HandleT) GetAllDestinations() []DestinationConnectionsT

func (*HandleT) GetAllSources added in v1.1.0 

func (cd *HandleT) GetAllSources() []SourceConnectionsT

func (*HandleT) GetConnectionByID added in v1.1.0 

func (cd *HandleT) GetConnectionByID(ID int) (ConnectionInstanceT, error)

func (*HandleT) GetDestinationByID added in v1.1.0 

func (cd *HandleT) GetDestinationByID(ID int) (DestinationInstanceT, error)

func (*HandleT) GetDestinationDetailByID added in v1.1.0 

func (cd *HandleT) GetDestinationDetailByID(ID int) (DestinationDetailT, error)

func (*HandleT) GetServiceCatalogue added in v1.1.0 

func (cd *HandleT) GetServiceCatalogue(service_type string) []ServiceCatalogueT

func (*HandleT) GetServiceCatalogueByID added in v1.1.0 

func (cd *HandleT) GetServiceCatalogueByID(ID int) (ServiceCatalogueT, error)

func (*HandleT) GetSourceByID added in v1.1.0 

func (cd *HandleT) GetSourceByID(ID int) (SourceInstanceT, error)

func (*HandleT) GetSourceDetailByID added in v1.1.0 

func (cd *HandleT) GetSourceDetailByID(ID int) (SourceDetailT, error)

func (*HandleT) Init 

func (cd *HandleT) Init()

Setup backend config

func (*HandleT) PollConfigUpdate added in v1.1.0 

func (cd *HandleT) PollConfigUpdate()

func (*HandleT) Setup 

func (cd *HandleT) Setup()

func (*HandleT) UpdateConnection added in v1.1.0 

func (cd *HandleT) UpdateConnection(connection ConnectionInstanceT) bool

func (*HandleT) UpdateDestination added in v1.1.0 

func (cd *HandleT) UpdateDestination(destination DestinationInstanceT) bool

func (*HandleT) UpdateSource added in v1.1.0 

func (cd *HandleT) UpdateSource(source SourceInstanceT) bool

type ServiceCatalogueT added in v1.1.0 

type ServiceCatalogueT struct {
	ID       int    `json:"id"`
	Name     string `json:"name"`
	Type     string `json:"type"`
	Access   string `json:"access"`
	Category string `json:"category"`
	Url      string `json:"url"`
	Notes    string `json:"notes"`
	MetaData string `json:"metadata"`
	IconUrl  string `json:"iconurl"`
}

type SourceConnectionsT added in v1.1.0 

type SourceConnectionsT struct {
	SourceDetail       SourceDetailT        `json:"source_detail"`
	DestinationDetails []DestinationDetailT `json:"destination_details"`
}

type SourceDefinitionT 

type SourceDefinitionT struct {
	ID       string `json:"sourceId"`
	Name     string `json:"sourceName"`
	Category string `json:"category"`
}

type SourceDetailT added in v1.1.0 

type SourceDetailT struct {
	Source    SourceInstanceT   `json:"source"`
	Catalogue ServiceCatalogueT `json:"catalogue"`
}

type SourceInstanceT added in v1.1.0 

type SourceInstanceT struct {
	ID           int    `json:"id"`
	Name         string `json:"name"`
	ServiceID    int    `json:"service_id"`
	WriteKey     string `json:"write_key"`
	CustomerID   int    `json:"customer_id"`
	CustomerName string `json:"customer_name"`
	SecretKey    string `json:"secret_key"`
	Config       string `json:"config"`
	Status       string `json:"status"`
}

func (SourceInstanceT) Disabled added in v1.1.0 

func (source SourceInstanceT) Disabled() bool

func (SourceInstanceT) Enabled added in v1.1.0 

func (source SourceInstanceT) Enabled() bool

type SourceT 

type SourceT struct {
	ID               string                 `json:"id"`
	Name             string                 `json:"sourceName"`
	SourceDefinition SourceDefinitionT      `json:"sourceDefinition"`
	Config           map[string]interface{} `json:"config"`
	Enabled          bool                   `json:"enabled"`
	Destinations     []DestinationT         `json:"destinations"`
	WriteKey         string                 `json:"writeKey"`
}

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

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.