Documentation ¶
Index ¶
- func NewPlugin(endpoint string) integration.Plugin
- type Plugin
- func (p *Plugin) ActiveRunsListTopic() string
- func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{})
- func (p *Plugin) Destroy() error
- func (p *Plugin) ErrorLoggerCallback(msg string, a ...interface{})
- func (p *Plugin) FSMEnterStateTopic(state string) string
- func (p *Plugin) FSMLeaveStateTopic(state string) string
- func (p *Plugin) GetConnectionState() string
- func (p *Plugin) GetData(environmentIds []uid.ID) string
- func (p *Plugin) GetEndpoint() string
- func (p *Plugin) GetName() string
- func (p *Plugin) GetPrettyName() string
- func (p *Plugin) GetRunningEnvList() []*kafkapb.EnvInfo
- func (p *Plugin) Init(_ string) error
- func (p *Plugin) LoggerCallback(msg string, a ...interface{})
- func (p *Plugin) ObjectStack(_ map[string]string) (stack map[string]interface{})
- func (p *Plugin) StartActivityTopic(trigger string) string
- func (p *Plugin) UpdateRunningEnvList(envInfo *kafkapb.EnvInfo)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPlugin ¶
func NewPlugin(endpoint string) integration.Plugin
Types ¶
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
func (*Plugin) ActiveRunsListTopic ¶
func (*Plugin) ErrorLoggerCallback ¶ added in v0.45.2
func (*Plugin) FSMEnterStateTopic ¶ added in v0.41.0
func (*Plugin) FSMLeaveStateTopic ¶ added in v0.41.0
func (*Plugin) GetConnectionState ¶
func (*Plugin) GetEndpoint ¶
func (*Plugin) GetPrettyName ¶
func (*Plugin) GetRunningEnvList ¶
func (*Plugin) LoggerCallback ¶ added in v0.45.2
func (*Plugin) ObjectStack ¶
func (*Plugin) StartActivityTopic ¶ added in v0.49.0
func (*Plugin) UpdateRunningEnvList ¶
Click to show internal directories.
Click to hide internal directories.