kafka

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(_ []any) string
  • func (p *Plugin) GetEndpoint() string
  • func (p *Plugin) GetEnvironmentsData(_ []uid.ID) map[uid.ID]string
  • func (p *Plugin) GetEnvironmentsShortData(_ []uid.ID) map[uid.ID]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, _ map[string]string) (stack map[string]interface{})
  • func (p *Plugin) StartActivityTopic(trigger string) string
  • func (p *Plugin) UpdateRunningEnvList(envInfo *kafkapb.EnvInfo)

Functions

func NewPlugin

func NewPlugin(endpoint string) integration.Plugin

Types

type Plugin

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

func (*Plugin) ActiveRunsListTopic

func (p *Plugin) ActiveRunsListTopic() string

func (*Plugin) CallStack

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

func (*Plugin) Destroy

func (p *Plugin) Destroy() error

func (*Plugin) ErrorLoggerCallback

func (p *Plugin) ErrorLoggerCallback(msg string, a ...interface{})

func (*Plugin) FSMEnterStateTopic

func (p *Plugin) FSMEnterStateTopic(state string) string

func (*Plugin) FSMLeaveStateTopic

func (p *Plugin) FSMLeaveStateTopic(state string) string

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(_ []uid.ID) map[uid.ID]string

func (*Plugin) GetEnvironmentsShortData

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

func (*Plugin) GetName

func (p *Plugin) GetName() string

func (*Plugin) GetPrettyName

func (p *Plugin) GetPrettyName() string

func (*Plugin) GetRunningEnvList

func (p *Plugin) GetRunningEnvList() []*kafkapb.EnvInfo

func (*Plugin) Init

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

func (*Plugin) LoggerCallback

func (p *Plugin) LoggerCallback(msg string, a ...interface{})

func (*Plugin) ObjectStack

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

func (*Plugin) StartActivityTopic

func (p *Plugin) StartActivityTopic(trigger string) string

func (*Plugin) UpdateRunningEnvList

func (p *Plugin) UpdateRunningEnvList(envInfo *kafkapb.EnvInfo)