kafka2mqtt_api

package
v0.0.7 Latest Latest
Warning

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

Go to latest
Published: Feb 26, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Instance

type Instance struct {
	FilterType          string    `json:"FilterType,omitempty" validate:"required"`
	Filter              string    `json:"Filter,omitempty" validate:"required"`
	Name                string    `json:"Name,omitempty" validate:"required"`
	EntityName          string    `json:"EntityName,omitempty" validate:"required"`
	ServiceName         string    `json:"ServiceName,omitempty" validate:"required"`
	Description         string    `json:"Description,omitempty"`
	Topic               string    `json:"Topic,omitempty" validate:"required"`
	Generated           bool      `json:"generated,omitempty"`
	Offset              string    `json:"Offset,omitempty" validate:"required"`
	Values              []Value   `json:"Values,omitempty"`
	UserId              string    `json:"-"`
	ServiceId           string    `json:"-"`
	CustomMqttBroker    *string   `json:"CustomMqttBroker,omitempty"`
	CustomMqttUser      *string   `json:"CustomMqttUser,omitempty"`
	CustomMqttPassword  *string   `json:"CustomMqttPassword,omitempty"`
	CustomMqttBaseTopic *string   `json:"CustomMqttBaseTopic,omitempty"`
	Id                  string    `json:"ID"`
	CreatedAt           time.Time `json:"CreatedAt"`
	UpdatedAt           time.Time `json:"UpdatedAt"`
}

type Kafka2MqttApi

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

func NewKafka2MqttApi

func NewKafka2MqttApi(url string) *Kafka2MqttApi

func (*Kafka2MqttApi) RemoveInstance

func (api *Kafka2MqttApi) RemoveInstance(id, pipelineID, userID, token string) error

func (*Kafka2MqttApi) StartOperatorInstance

func (api *Kafka2MqttApi) StartOperatorInstance(operatorName, operatorID string, pipelineId string, userID, token string) (createdInstance Instance, err error)

type Value

type Value struct {
	Name string `json:"Name"`
	Path string `json:"Path"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL