Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var RootCmd corecmd.AgentRootCmd
RootCmd - Agent root command
Functions ¶
func DerefString ¶
DerefString - dereferences a string and returns zero-length string if NIL
func GetAgentConfig ¶
func GetAgentConfig() *config.ConnectorConfig
GetAgentConfig agent configuration
Types ¶
type SubscriptionSchemaProcessorClientOriginJob ¶ added in v0.0.18
SubscriptionSchemaProcessorJob - the job
func (*SubscriptionSchemaProcessorClientOriginJob) Execute ¶ added in v0.0.18
func (j *SubscriptionSchemaProcessorClientOriginJob) Execute() error
Execute - executes this job
func (*SubscriptionSchemaProcessorClientOriginJob) Ready ¶ added in v0.0.18
func (j *SubscriptionSchemaProcessorClientOriginJob) Ready() bool
Ready - is this job ready
func (*SubscriptionSchemaProcessorClientOriginJob) Status ¶ added in v0.0.18
func (j *SubscriptionSchemaProcessorClientOriginJob) Status() error
Status - the status of this job
type SubscriptionSchemaProcessorJob ¶
SubscriptionSchemaProcessorJob - the job
func (*SubscriptionSchemaProcessorJob) Execute ¶
func (j *SubscriptionSchemaProcessorJob) Execute() error
Execute - executes this job
func (*SubscriptionSchemaProcessorJob) Ready ¶
func (j *SubscriptionSchemaProcessorJob) Ready() bool
Ready - is this job ready
func (*SubscriptionSchemaProcessorJob) Status ¶
func (j *SubscriptionSchemaProcessorJob) Status() error
Status - the status of this job
type SubscriptionSchemaPublisherClientOriginJob ¶ added in v0.0.18
SubscriptionSchemaPublisherJob the publishing job
func (*SubscriptionSchemaPublisherClientOriginJob) Execute ¶ added in v0.0.18
func (j *SubscriptionSchemaPublisherClientOriginJob) Execute() error
Execute - executes this job
func (*SubscriptionSchemaPublisherClientOriginJob) Ready ¶ added in v0.0.18
func (j *SubscriptionSchemaPublisherClientOriginJob) Ready() bool
Ready - is this job ready
func (*SubscriptionSchemaPublisherClientOriginJob) Status ¶ added in v0.0.18
func (j *SubscriptionSchemaPublisherClientOriginJob) Status() error
Status - of this job
type SubscriptionSchemaPublisherJob ¶
SubscriptionSchemaPublisherJob the publishing job
func (*SubscriptionSchemaPublisherJob) Execute ¶
func (j *SubscriptionSchemaPublisherJob) Execute() error
Execute - executes this job
func (*SubscriptionSchemaPublisherJob) Ready ¶
func (j *SubscriptionSchemaPublisherJob) Ready() bool
Ready - is this job ready
func (*SubscriptionSchemaPublisherJob) Status ¶
func (j *SubscriptionSchemaPublisherJob) Status() error
Status - of this job
Click to show internal directories.
Click to hide internal directories.