dcs

Documentation

Index

• Constants
• func NewPlugin(endpoint string) integration.Plugin
• type DCSDetectorInfoMap
  • func (m DCSDetectorInfoMap) ToEcsDetectors() ECSDetectorInfoMap
• type DCSDetectorOpAvailabilityMap
  • func (dsm DCSDetectorOpAvailabilityMap) EcsDetectorsMap() (sm map[string]string)
  • func (dsm DCSDetectorOpAvailabilityMap) ToStringMap() (sm map[string]string)
• type DCSDetectors
  • func (d DCSDetectors) EcsDetectorsSlice() (sslice []string)
  • func (d DCSDetectors) ToStringSlice() (sslice []string)
• type ECSDetectorInfo
• type ECSDetectorInfoMap
  • func (m ECSDetectorInfoMap) Filtered(detectorList []string) ECSDetectorInfoMap
• type PartitionInfo
• type Plugin
  • func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{})
  • func (p *Plugin) Destroy() error
  • func (p *Plugin) GetConnectionState() string
  • func (p *Plugin) GetData(_ []any) string
  • func (p *Plugin) GetEndpoint() string
  • func (p *Plugin) GetEnvironmentsData(environmentIds []uid.ID) map[uid.ID]string
  • func (p *Plugin) GetEnvironmentsShortData(environmentIds []uid.ID) map[uid.ID]string
  • func (p *Plugin) GetName() string
  • func (p *Plugin) GetPrettyName() string
  • func (p *Plugin) Init(instanceId string) error
  • func (p *Plugin) ObjectStack(_ map[string]string, _ map[string]string) (stack map[string]interface{})
• type RpcClient
  • func NewClient(cxt context.Context, cancel context.CancelFunc, endpoint string) *RpcClient
  • func (m *RpcClient) Close() error
  • func (m *RpcClient) GetConnState() connectivity.State

Constants

const (
	DCS_DIAL_TIMEOUT       = 2 * time.Hour
	DCS_GENERAL_OP_TIMEOUT = 45 * time.Second
	DCS_TIME_FORMAT        = "2006-01-02 15:04:05.000"
	TOPIC                  = topic.IntegratedService + topic.Separator + "dcs"
)

Functions

func NewPlugin

func NewPlugin(endpoint string) integration.Plugin

Types

type DCSDetectorInfoMap

type DCSDetectorInfoMap map[dcspb.Detector]*dcspb.DetectorInfo

func (DCSDetectorInfoMap) ToEcsDetectors

func (m DCSDetectorInfoMap) ToEcsDetectors() ECSDetectorInfoMap

type DCSDetectorOpAvailabilityMap

type DCSDetectorOpAvailabilityMap map[dcspb.Detector]dcspb.DetectorState

func (DCSDetectorOpAvailabilityMap) EcsDetectorsMap

func (dsm DCSDetectorOpAvailabilityMap) EcsDetectorsMap() (sm map[string]string)

func (DCSDetectorOpAvailabilityMap) ToStringMap

func (dsm DCSDetectorOpAvailabilityMap) ToStringMap() (sm map[string]string)

type DCSDetectors

type DCSDetectors []dcspb.Detector

func (DCSDetectors) EcsDetectorsSlice

func (d DCSDetectors) EcsDetectorsSlice() (sslice []string)

func (DCSDetectors) ToStringSlice

func (d DCSDetectors) ToStringSlice() (sslice []string)

type ECSDetectorInfo

type ECSDetectorInfo struct {
	State           string
	Timestamp       string
	AllowedRunTypes []string
	PfrAvailability string
	SorAvailability string
}

type ECSDetectorInfoMap

type ECSDetectorInfoMap map[string]ECSDetectorInfo

func (ECSDetectorInfoMap) Filtered

func (m ECSDetectorInfoMap) Filtered(detectorList []string) ECSDetectorInfoMap

type PartitionInfo

type PartitionInfo struct {
	SorSuccessful bool
	Detectors     ECSDetectorInfoMap
}

type Plugin

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

func (*Plugin) CallStack

func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{})

func (*Plugin) Destroy

func (p *Plugin) Destroy() error

func (*Plugin) GetConnectionState

func (p *Plugin) GetConnectionState() string

func (*Plugin) GetData

func (p *Plugin) GetData(_ []any) string

func (*Plugin) GetEndpoint

func (p *Plugin) GetEndpoint() string

func (*Plugin) GetEnvironmentsData

func (p *Plugin) GetEnvironmentsData(environmentIds []uid.ID) map[uid.ID]string

func (*Plugin) GetEnvironmentsShortData

func (p *Plugin) GetEnvironmentsShortData(environmentIds []uid.ID) map[uid.ID]string

func (*Plugin) GetName

func (p *Plugin) GetName() string

func (*Plugin) GetPrettyName

func (p *Plugin) GetPrettyName() string

func (*Plugin) Init

func (p *Plugin) Init(instanceId string) error

func (*Plugin) ObjectStack

func (p *Plugin) ObjectStack(_ map[string]string, _ map[string]string) (stack map[string]interface{})

type RpcClient

type RpcClient struct {
	dcspb.ConfiguratorClient
	// contains filtered or unexported fields
}

func NewClient

func NewClient(cxt context.Context, cancel context.CancelFunc, endpoint string) *RpcClient

func (*RpcClient) Close

func (m *RpcClient) Close() error

func (*RpcClient) GetConnState

func (m *RpcClient) GetConnState() connectivity.State