opts

package
v0.0.51 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2021 License: Apache-2.0 Imports: 6 Imported by: 41

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ConvertOption_name = map[int32]string{
	0: "CONVERT_OPTION_UNSET",
	1: "CONVERT_OPTION_BASE64",
	2: "CONVERT_OPTION_GZIP",
}
View Source 
var ConvertOption_value = map[string]int32{
	"CONVERT_OPTION_UNSET":  0,
	"CONVERT_OPTION_BASE64": 1,
	"CONVERT_OPTION_GZIP":   2,
}

Functions

This section is empty.

Types

type CLIOptions added in v0.0.51 

type CLIOptions struct {
	// @gotags: kong:"embed"
	Global *GlobalCLIOptions `protobuf:"bytes,1,opt,name=global,proto3" json:"global,omitempty" kong:"embed"`
	// @gotags: kong:"cmd,help='Read message(s) from messaging system'"
	Read *ReadOptions `protobuf:"bytes,2,opt,name=read,proto3" json:"read,omitempty" kong:"cmd,help='Read message(s) from messaging system'"`
	// @gotags: kong:"cmd,help='Write message(s) to messaging system'"
	Write *WriteOptions `protobuf:"bytes,3,opt,name=write,proto3" json:"write,omitempty" kong:"cmd,help='Write message(s) to messaging system'"`
	// @gotags: kong:"cmd,help='Relay message(s) from messaging system to Batch'"
	Relay *RelayOptions `` /* 129-byte string literal not displayed */
	// @gotags: kong:"cmd,group=server,help='Run plumber in server mode'"
	Server               *ServerOptions `protobuf:"bytes,5,opt,name=server,proto3" json:"server,omitempty" kong:"cmd,group=server,help='Run plumber in server mode'"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

CLI options in plumber are derived 100% from the protobuf schemas. The CLIOptions type is used for populating base CLI options. Introducing a top-level CLI option should begin here (and trickle all the way down to any newly introduced types).

For more info, check README_CLI.md

func (*CLIOptions) Descriptor added in v0.0.51 

func (*CLIOptions) Descriptor() ([]byte, []int)

func (*CLIOptions) GetGlobal added in v0.0.51 

func (m *CLIOptions) GetGlobal() *GlobalCLIOptions

func (*CLIOptions) GetRead added in v0.0.51 

func (m *CLIOptions) GetRead() *ReadOptions

func (*CLIOptions) GetRelay added in v0.0.51 

func (m *CLIOptions) GetRelay() *RelayOptions

func (*CLIOptions) GetServer added in v0.0.51 

func (m *CLIOptions) GetServer() *ServerOptions

func (*CLIOptions) GetWrite added in v0.0.51 

func (m *CLIOptions) GetWrite() *WriteOptions

func (*CLIOptions) ProtoMessage added in v0.0.51 

func (*CLIOptions) ProtoMessage()

func (*CLIOptions) Reset added in v0.0.51 

func (m *CLIOptions) Reset()

func (*CLIOptions) String added in v0.0.51 

func (m *CLIOptions) String() string

func (*CLIOptions) XXX_DiscardUnknown added in v0.0.51 

func (m *CLIOptions) XXX_DiscardUnknown()

func (*CLIOptions) XXX_Marshal added in v0.0.51 

func (m *CLIOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CLIOptions) XXX_Merge added in v0.0.51 

func (m *CLIOptions) XXX_Merge(src proto.Message)

func (*CLIOptions) XXX_Size added in v0.0.51 

func (m *CLIOptions) XXX_Size() int

func (*CLIOptions) XXX_Unmarshal added in v0.0.51 

func (m *CLIOptions) XXX_Unmarshal(b []byte) error

type ConnectionOptions added in v0.0.49 

type ConnectionOptions struct {
	// Friendly name to identify this connection by (used in plumber-server logs)
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Any notes associated with this connection (stored plumber-server side)
	Notes string `protobuf:"bytes,2,opt,name=notes,proto3" json:"notes,omitempty"`
	// Types that are valid to be assigned to Conn:
	//	*ConnectionOptions_Kafka
	//	*ConnectionOptions_ActiveMq
	//	*ConnectionOptions_Awssqs
	//	*ConnectionOptions_Awssns
	//	*ConnectionOptions_Mongo
	//	*ConnectionOptions_Nats
	//	*ConnectionOptions_NatsStreaming
	//	*ConnectionOptions_Nsq
	//	*ConnectionOptions_Postgres
	//	*ConnectionOptions_Pulsar
	//	*ConnectionOptions_Rabbit
	//	*ConnectionOptions_RabbitStreams
	//	*ConnectionOptions_RedisPubsub
	//	*ConnectionOptions_RedisStreams
	//	*ConnectionOptions_AzureEventHub
	//	*ConnectionOptions_AzureServiceBus
	//	*ConnectionOptions_Mqtt
	//	*ConnectionOptions_KubemqQueue
	//	*ConnectionOptions_GcpPubsub
	Conn isConnectionOptions_Conn `protobuf_oneof:"conn"`
	// Used internally by plumber
	XId                  string   `protobuf:"bytes,1000,opt,name=_id,json=Id,proto3" json:"_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ConnectionConfig is used for creating a new backend. CLI creates an instance of this structure by injecting the conn struct it receives via *Args.

func (*ConnectionOptions) Descriptor added in v0.0.49 

func (*ConnectionOptions) Descriptor() ([]byte, []int)

func (*ConnectionOptions) GetActiveMq added in v0.0.49 

func (m *ConnectionOptions) GetActiveMq() *args.ActiveMQConn

func (*ConnectionOptions) GetAwssns added in v0.0.49 

func (m *ConnectionOptions) GetAwssns() *args.AWSSNSConn

func (*ConnectionOptions) GetAwssqs added in v0.0.49 

func (m *ConnectionOptions) GetAwssqs() *args.AWSSQSConn

func (*ConnectionOptions) GetAzureEventHub added in v0.0.49 

func (m *ConnectionOptions) GetAzureEventHub() *args.AzureEventHubConn

func (*ConnectionOptions) GetAzureServiceBus added in v0.0.49 

func (m *ConnectionOptions) GetAzureServiceBus() *args.AzureServiceBusConn

func (*ConnectionOptions) GetConn added in v0.0.49 

func (m *ConnectionOptions) GetConn() isConnectionOptions_Conn

func (*ConnectionOptions) GetGcpPubsub added in v0.0.49 

func (m *ConnectionOptions) GetGcpPubsub() *args.GCPPubSubConn

func (*ConnectionOptions) GetKafka added in v0.0.49 

func (m *ConnectionOptions) GetKafka() *args.KafkaConn

func (*ConnectionOptions) GetKubemqQueue added in v0.0.49 

func (m *ConnectionOptions) GetKubemqQueue() *args.KubeMQQueueConn

func (*ConnectionOptions) GetMongo added in v0.0.49 

func (m *ConnectionOptions) GetMongo() *args.MongoConn

func (*ConnectionOptions) GetMqtt added in v0.0.49 

func (m *ConnectionOptions) GetMqtt() *args.MQTTConn

func (*ConnectionOptions) GetName added in v0.0.49 

func (m *ConnectionOptions) GetName() string

func (*ConnectionOptions) GetNats added in v0.0.49 

func (m *ConnectionOptions) GetNats() *args.NatsConn

func (*ConnectionOptions) GetNatsStreaming added in v0.0.49 

func (m *ConnectionOptions) GetNatsStreaming() *args.NatsStreamingConn

func (*ConnectionOptions) GetNotes added in v0.0.49 

func (m *ConnectionOptions) GetNotes() string

func (*ConnectionOptions) GetNsq added in v0.0.49 

func (m *ConnectionOptions) GetNsq() *args.NSQConn

func (*ConnectionOptions) GetPostgres added in v0.0.49 

func (m *ConnectionOptions) GetPostgres() *args.PostgresConn

func (*ConnectionOptions) GetPulsar added in v0.0.49 

func (m *ConnectionOptions) GetPulsar() *args.PulsarConn

func (*ConnectionOptions) GetRabbit added in v0.0.49 

func (m *ConnectionOptions) GetRabbit() *args.RabbitConn

func (*ConnectionOptions) GetRabbitStreams added in v0.0.49 

func (m *ConnectionOptions) GetRabbitStreams() *args.RabbitStreamsConn

func (*ConnectionOptions) GetRedisPubsub added in v0.0.49 

func (m *ConnectionOptions) GetRedisPubsub() *args.RedisPubSubConn

func (*ConnectionOptions) GetRedisStreams added in v0.0.49 

func (m *ConnectionOptions) GetRedisStreams() *args.RedisStreamsConn

func (*ConnectionOptions) GetXId added in v0.0.49 

func (m *ConnectionOptions) GetXId() string

func (*ConnectionOptions) ProtoMessage added in v0.0.49 

func (*ConnectionOptions) ProtoMessage()

func (*ConnectionOptions) Reset added in v0.0.49 

func (m *ConnectionOptions) Reset()

func (*ConnectionOptions) String added in v0.0.49 

func (m *ConnectionOptions) String() string

func (*ConnectionOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ConnectionOptions) XXX_DiscardUnknown()

func (*ConnectionOptions) XXX_Marshal added in v0.0.49 

func (m *ConnectionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionOptions) XXX_Merge added in v0.0.49 

func (m *ConnectionOptions) XXX_Merge(src proto.Message)

func (*ConnectionOptions) XXX_OneofWrappers added in v0.0.49 

func (*ConnectionOptions) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConnectionOptions) XXX_Size added in v0.0.49 

func (m *ConnectionOptions) XXX_Size() int

func (*ConnectionOptions) XXX_Unmarshal added in v0.0.49 

func (m *ConnectionOptions) XXX_Unmarshal(b []byte) error

type ConnectionOptions_ActiveMq added in v0.0.49 

type ConnectionOptions_ActiveMq struct {
	ActiveMq *args.ActiveMQConn `protobuf:"bytes,101,opt,name=active_mq,json=activeMq,proto3,oneof"`
}

type ConnectionOptions_Awssns added in v0.0.49 

type ConnectionOptions_Awssns struct {
	Awssns *args.AWSSNSConn `protobuf:"bytes,103,opt,name=awssns,proto3,oneof"`
}

type ConnectionOptions_Awssqs added in v0.0.49 

type ConnectionOptions_Awssqs struct {
	Awssqs *args.AWSSQSConn `protobuf:"bytes,102,opt,name=awssqs,proto3,oneof"`
}

type ConnectionOptions_AzureEventHub added in v0.0.49 

type ConnectionOptions_AzureEventHub struct {
	AzureEventHub *args.AzureEventHubConn `protobuf:"bytes,114,opt,name=azure_event_hub,json=azureEventHub,proto3,oneof"`
}

type ConnectionOptions_AzureServiceBus added in v0.0.49 

type ConnectionOptions_AzureServiceBus struct {
	AzureServiceBus *args.AzureServiceBusConn `protobuf:"bytes,115,opt,name=azure_service_bus,json=azureServiceBus,proto3,oneof"`
}

type ConnectionOptions_GcpPubsub added in v0.0.49 

type ConnectionOptions_GcpPubsub struct {
	GcpPubsub *args.GCPPubSubConn `protobuf:"bytes,118,opt,name=gcp_pubsub,json=gcpPubsub,proto3,oneof"`
}

type ConnectionOptions_Kafka added in v0.0.49 

type ConnectionOptions_Kafka struct {
	Kafka *args.KafkaConn `protobuf:"bytes,100,opt,name=kafka,proto3,oneof"`
}

type ConnectionOptions_KubemqQueue added in v0.0.49 

type ConnectionOptions_KubemqQueue struct {
	KubemqQueue *args.KubeMQQueueConn `protobuf:"bytes,117,opt,name=kubemq_queue,json=kubemqQueue,proto3,oneof"`
}

type ConnectionOptions_Mongo added in v0.0.49 

type ConnectionOptions_Mongo struct {
	Mongo *args.MongoConn `protobuf:"bytes,104,opt,name=mongo,proto3,oneof"`
}

type ConnectionOptions_Mqtt added in v0.0.49 

type ConnectionOptions_Mqtt struct {
	Mqtt *args.MQTTConn `protobuf:"bytes,116,opt,name=mqtt,proto3,oneof"`
}

type ConnectionOptions_Nats added in v0.0.49 

type ConnectionOptions_Nats struct {
	Nats *args.NatsConn `protobuf:"bytes,105,opt,name=nats,proto3,oneof"`
}

type ConnectionOptions_NatsStreaming added in v0.0.49 

type ConnectionOptions_NatsStreaming struct {
	NatsStreaming *args.NatsStreamingConn `protobuf:"bytes,106,opt,name=nats_streaming,json=natsStreaming,proto3,oneof"`
}

type ConnectionOptions_Nsq added in v0.0.49 

type ConnectionOptions_Nsq struct {
	Nsq *args.NSQConn `protobuf:"bytes,107,opt,name=nsq,proto3,oneof"`
}

type ConnectionOptions_Postgres added in v0.0.49 

type ConnectionOptions_Postgres struct {
	Postgres *args.PostgresConn `protobuf:"bytes,108,opt,name=postgres,proto3,oneof"`
}

type ConnectionOptions_Pulsar added in v0.0.49 

type ConnectionOptions_Pulsar struct {
	Pulsar *args.PulsarConn `protobuf:"bytes,109,opt,name=pulsar,proto3,oneof"`
}

type ConnectionOptions_Rabbit added in v0.0.49 

type ConnectionOptions_Rabbit struct {
	Rabbit *args.RabbitConn `protobuf:"bytes,110,opt,name=rabbit,proto3,oneof"`
}

type ConnectionOptions_RabbitStreams added in v0.0.49 

type ConnectionOptions_RabbitStreams struct {
	RabbitStreams *args.RabbitStreamsConn `protobuf:"bytes,111,opt,name=rabbit_streams,json=rabbitStreams,proto3,oneof"`
}

type ConnectionOptions_RedisPubsub added in v0.0.49 

type ConnectionOptions_RedisPubsub struct {
	RedisPubsub *args.RedisPubSubConn `protobuf:"bytes,112,opt,name=redis_pubsub,json=redisPubsub,proto3,oneof"`
}

type ConnectionOptions_RedisStreams added in v0.0.49 

type ConnectionOptions_RedisStreams struct {
	RedisStreams *args.RedisStreamsConn `protobuf:"bytes,113,opt,name=redis_streams,json=redisStreams,proto3,oneof"`
}

type ConvertOption added in v0.0.49 

type ConvertOption int32
const (
	ConvertOption_CONVERT_OPTION_UNSET  ConvertOption = 0
	ConvertOption_CONVERT_OPTION_BASE64 ConvertOption = 1
	ConvertOption_CONVERT_OPTION_GZIP   ConvertOption = 2
)

func (ConvertOption) EnumDescriptor added in v0.0.49 

func (ConvertOption) EnumDescriptor() ([]byte, []int)

func (ConvertOption) String added in v0.0.49 

func (x ConvertOption) String() string

type GlobalCLIOptions added in v0.0.51 

type GlobalCLIOptions struct {
	// @gotags: kong:"help='Enable debug output',short=d"
	Debug bool `protobuf:"varint,1,opt,name=debug,proto3" json:"debug,omitempty" kong:"help='Enable debug output',short=d"`
	// @gotags: kong:"help='Disable fancy output (like curl -s)',short=q"
	Quiet bool `protobuf:"varint,2,opt,name=quiet,proto3" json:"quiet,omitempty" kong:"help='Disable fancy output (like curl -s)',short=q"`
	// @gotags: kong:"help='Display plumber version'"
	Version bool `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty" kong:"help='Display plumber version'"`
	// @gotags: kong:"-"
	XFullCommand string `protobuf:"bytes,1000,opt,name=_full_command,json=FullCommand,proto3" json:"_full_command,omitempty" kong:"-"`
	// @gotags: kong:"-"
	XAction string `protobuf:"bytes,1001,opt,name=_action,json=Action,proto3" json:"_action,omitempty" kong:"-"`
	// @gotags: kong:"-"
	XBackend             string   `protobuf:"bytes,1002,opt,name=_backend,json=Backend,proto3" json:"_backend,omitempty" kong:"-"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GlobalCLIOptions) Descriptor added in v0.0.51 

func (*GlobalCLIOptions) Descriptor() ([]byte, []int)

func (*GlobalCLIOptions) GetDebug added in v0.0.51 

func (m *GlobalCLIOptions) GetDebug() bool

func (*GlobalCLIOptions) GetQuiet added in v0.0.51 

func (m *GlobalCLIOptions) GetQuiet() bool

func (*GlobalCLIOptions) GetVersion added in v0.0.51 

func (m *GlobalCLIOptions) GetVersion() bool

func (*GlobalCLIOptions) GetXAction added in v0.0.51 

func (m *GlobalCLIOptions) GetXAction() string

func (*GlobalCLIOptions) GetXBackend added in v0.0.51 

func (m *GlobalCLIOptions) GetXBackend() string

func (*GlobalCLIOptions) GetXFullCommand added in v0.0.51 

func (m *GlobalCLIOptions) GetXFullCommand() string

func (*GlobalCLIOptions) ProtoMessage added in v0.0.51 

func (*GlobalCLIOptions) ProtoMessage()

func (*GlobalCLIOptions) Reset added in v0.0.51 

func (m *GlobalCLIOptions) Reset()

func (*GlobalCLIOptions) String added in v0.0.51 

func (m *GlobalCLIOptions) String() string

func (*GlobalCLIOptions) XXX_DiscardUnknown added in v0.0.51 

func (m *GlobalCLIOptions) XXX_DiscardUnknown()

func (*GlobalCLIOptions) XXX_Marshal added in v0.0.51 

func (m *GlobalCLIOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalCLIOptions) XXX_Merge added in v0.0.51 

func (m *GlobalCLIOptions) XXX_Merge(src proto.Message)

func (*GlobalCLIOptions) XXX_Size added in v0.0.51 

func (m *GlobalCLIOptions) XXX_Size() int

func (*GlobalCLIOptions) XXX_Unmarshal added in v0.0.51 

func (m *GlobalCLIOptions) XXX_Unmarshal(b []byte) error

type IsConnectionOptions_Conn added in v0.0.49 

type IsConnectionOptions_Conn = isConnectionOptions_Conn

type ReadCLIOptions added in v0.0.49 

type ReadCLIOptions struct {
	// @gotags: kong:"help='Convert output before it is printed to STDOUT (1 = base64, 2 = gzip)',enum"
	ConvertOutput []ConvertOption `` /* 227-byte string literal not displayed */
	// @gotags: kong:"help='Display more verbose information during reads (varies by backend)'"
	VerboseOutput bool `` /* 181-byte string literal not displayed */
	// @gotags: kong:"group=stats,help='Display periodic read stats'"
	StatsEnable bool `` /* 149-byte string literal not displayed */
	// @gotags: kong:"group=stats,help='How often to print stats',default=5"
	StatsReportIntervalSec int32    `` /* 193-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*ReadCLIOptions) Descriptor added in v0.0.49 

func (*ReadCLIOptions) Descriptor() ([]byte, []int)

func (*ReadCLIOptions) GetConvertOutput added in v0.0.49 

func (m *ReadCLIOptions) GetConvertOutput() []ConvertOption

func (*ReadCLIOptions) GetStatsEnable added in v0.0.49 

func (m *ReadCLIOptions) GetStatsEnable() bool

func (*ReadCLIOptions) GetStatsReportIntervalSec added in v0.0.49 

func (m *ReadCLIOptions) GetStatsReportIntervalSec() int32

func (*ReadCLIOptions) GetVerboseOutput added in v0.0.49 

func (m *ReadCLIOptions) GetVerboseOutput() bool

func (*ReadCLIOptions) ProtoMessage added in v0.0.49 

func (*ReadCLIOptions) ProtoMessage()

func (*ReadCLIOptions) Reset added in v0.0.49 

func (m *ReadCLIOptions) Reset()

func (*ReadCLIOptions) String added in v0.0.49 

func (m *ReadCLIOptions) String() string

func (*ReadCLIOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadCLIOptions) XXX_DiscardUnknown()

func (*ReadCLIOptions) XXX_Marshal added in v0.0.49 

func (m *ReadCLIOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadCLIOptions) XXX_Merge added in v0.0.49 

func (m *ReadCLIOptions) XXX_Merge(src proto.Message)

func (*ReadCLIOptions) XXX_Size added in v0.0.49 

func (m *ReadCLIOptions) XXX_Size() int

func (*ReadCLIOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadCLIOptions) XXX_Unmarshal(b []byte) error

type ReadGroupAWSSQSOptions added in v0.0.49 

type ReadGroupAWSSQSOptions struct {
	// @gotags: kong:"embed"
	XConn *args.AWSSQSConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.AWSSQSReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ReadGroupAWSSQSOptions) Descriptor added in v0.0.49 

func (*ReadGroupAWSSQSOptions) Descriptor() ([]byte, []int)

func (*ReadGroupAWSSQSOptions) GetArgs added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) GetArgs() *args.AWSSQSReadArgs

func (*ReadGroupAWSSQSOptions) GetXConn added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) GetXConn() *args.AWSSQSConn

func (*ReadGroupAWSSQSOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupAWSSQSOptions) ProtoMessage()

func (*ReadGroupAWSSQSOptions) Reset added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) Reset()

func (*ReadGroupAWSSQSOptions) String added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) String() string

func (*ReadGroupAWSSQSOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) XXX_DiscardUnknown()

func (*ReadGroupAWSSQSOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupAWSSQSOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) XXX_Merge(src proto.Message)

func (*ReadGroupAWSSQSOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) XXX_Size() int

func (*ReadGroupAWSSQSOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) XXX_Unmarshal(b []byte) error

type ReadGroupActiveMQOptions added in v0.0.49 

type ReadGroupActiveMQOptions struct {
	// @gotags: kong:"embed"
	XConn *args.ActiveMQConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.ActiveMQReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ReadGroupActiveMQOptions) Descriptor added in v0.0.49 

func (*ReadGroupActiveMQOptions) Descriptor() ([]byte, []int)

func (*ReadGroupActiveMQOptions) GetArgs added in v0.0.49 

func (m *ReadGroupActiveMQOptions) GetArgs() *args.ActiveMQReadArgs

func (*ReadGroupActiveMQOptions) GetXConn added in v0.0.49 

func (m *ReadGroupActiveMQOptions) GetXConn() *args.ActiveMQConn

func (*ReadGroupActiveMQOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupActiveMQOptions) ProtoMessage()

func (*ReadGroupActiveMQOptions) Reset added in v0.0.49 

func (m *ReadGroupActiveMQOptions) Reset()

func (*ReadGroupActiveMQOptions) String added in v0.0.49 

func (m *ReadGroupActiveMQOptions) String() string

func (*ReadGroupActiveMQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupActiveMQOptions) XXX_DiscardUnknown()

func (*ReadGroupActiveMQOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupActiveMQOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupActiveMQOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupActiveMQOptions) XXX_Merge(src proto.Message)

func (*ReadGroupActiveMQOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupActiveMQOptions) XXX_Size() int

func (*ReadGroupActiveMQOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupActiveMQOptions) XXX_Unmarshal(b []byte) error

type ReadGroupAzureEventHubOptions added in v0.0.49 

type ReadGroupAzureEventHubOptions struct {
	// @gotags: kong:"embed"
	XConn *args.AzureEventHubConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.AzureEventHubReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ReadGroupAzureEventHubOptions) Descriptor added in v0.0.49 

func (*ReadGroupAzureEventHubOptions) Descriptor() ([]byte, []int)

func (*ReadGroupAzureEventHubOptions) GetArgs added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) GetArgs() *args.AzureEventHubReadArgs

func (*ReadGroupAzureEventHubOptions) GetXConn added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) GetXConn() *args.AzureEventHubConn

func (*ReadGroupAzureEventHubOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupAzureEventHubOptions) ProtoMessage()

func (*ReadGroupAzureEventHubOptions) Reset added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) Reset()

func (*ReadGroupAzureEventHubOptions) String added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) String() string

func (*ReadGroupAzureEventHubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) XXX_DiscardUnknown()

func (*ReadGroupAzureEventHubOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupAzureEventHubOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) XXX_Merge(src proto.Message)

func (*ReadGroupAzureEventHubOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) XXX_Size() int

func (*ReadGroupAzureEventHubOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) XXX_Unmarshal(b []byte) error

type ReadGroupAzureServiceBusOptions added in v0.0.49 

type ReadGroupAzureServiceBusOptions struct {
	// @gotags: kong:"embed"
	XConn *args.AzureServiceBusConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.AzureServiceBusReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*ReadGroupAzureServiceBusOptions) Descriptor added in v0.0.49 

func (*ReadGroupAzureServiceBusOptions) Descriptor() ([]byte, []int)

func (*ReadGroupAzureServiceBusOptions) GetArgs added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) GetArgs() *args.AzureServiceBusReadArgs

func (*ReadGroupAzureServiceBusOptions) GetXConn added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) GetXConn() *args.AzureServiceBusConn

func (*ReadGroupAzureServiceBusOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupAzureServiceBusOptions) ProtoMessage()

func (*ReadGroupAzureServiceBusOptions) Reset added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) Reset()

func (*ReadGroupAzureServiceBusOptions) String added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) String() string

func (*ReadGroupAzureServiceBusOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) XXX_DiscardUnknown()

func (*ReadGroupAzureServiceBusOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupAzureServiceBusOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) XXX_Merge(src proto.Message)

func (*ReadGroupAzureServiceBusOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) XXX_Size() int

func (*ReadGroupAzureServiceBusOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) XXX_Unmarshal(b []byte) error

type ReadGroupGCPPubSubOptions added in v0.0.49 

type ReadGroupGCPPubSubOptions struct {
	// @gotags: kong:"embed"
	XConn *args.GCPPubSubConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.GCPPubSubReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ReadGroupGCPPubSubOptions) Descriptor added in v0.0.49 

func (*ReadGroupGCPPubSubOptions) Descriptor() ([]byte, []int)

func (*ReadGroupGCPPubSubOptions) GetArgs added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) GetArgs() *args.GCPPubSubReadArgs

func (*ReadGroupGCPPubSubOptions) GetXConn added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) GetXConn() *args.GCPPubSubConn

func (*ReadGroupGCPPubSubOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupGCPPubSubOptions) ProtoMessage()

func (*ReadGroupGCPPubSubOptions) Reset added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) Reset()

func (*ReadGroupGCPPubSubOptions) String added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) String() string

func (*ReadGroupGCPPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) XXX_DiscardUnknown()

func (*ReadGroupGCPPubSubOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupGCPPubSubOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) XXX_Merge(src proto.Message)

func (*ReadGroupGCPPubSubOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) XXX_Size() int

func (*ReadGroupGCPPubSubOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) XXX_Unmarshal(b []byte) error

type ReadGroupKafkaOptions added in v0.0.49 

type ReadGroupKafkaOptions struct {
	// @gotags: kong:"embed"
	XConn *args.KafkaConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.KafkaReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ReadGroupKafkaOptions) Descriptor added in v0.0.49 

func (*ReadGroupKafkaOptions) Descriptor() ([]byte, []int)

func (*ReadGroupKafkaOptions) GetArgs added in v0.0.49 

func (m *ReadGroupKafkaOptions) GetArgs() *args.KafkaReadArgs

func (*ReadGroupKafkaOptions) GetXConn added in v0.0.49 

func (m *ReadGroupKafkaOptions) GetXConn() *args.KafkaConn

func (*ReadGroupKafkaOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupKafkaOptions) ProtoMessage()

func (*ReadGroupKafkaOptions) Reset added in v0.0.49 

func (m *ReadGroupKafkaOptions) Reset()

func (*ReadGroupKafkaOptions) String added in v0.0.49 

func (m *ReadGroupKafkaOptions) String() string

func (*ReadGroupKafkaOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupKafkaOptions) XXX_DiscardUnknown()

func (*ReadGroupKafkaOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupKafkaOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupKafkaOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupKafkaOptions) XXX_Merge(src proto.Message)

func (*ReadGroupKafkaOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupKafkaOptions) XXX_Size() int

func (*ReadGroupKafkaOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupKafkaOptions) XXX_Unmarshal(b []byte) error

type ReadGroupKubeMQQueueOptions added in v0.0.49 

type ReadGroupKubeMQQueueOptions struct {
	// @gotags: kong:"embed"
	XConn *args.KubeMQQueueConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.KubeMQQueueReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ReadGroupKubeMQQueueOptions) Descriptor added in v0.0.49 

func (*ReadGroupKubeMQQueueOptions) Descriptor() ([]byte, []int)

func (*ReadGroupKubeMQQueueOptions) GetArgs added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) GetArgs() *args.KubeMQQueueReadArgs

func (*ReadGroupKubeMQQueueOptions) GetXConn added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) GetXConn() *args.KubeMQQueueConn

func (*ReadGroupKubeMQQueueOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupKubeMQQueueOptions) ProtoMessage()

func (*ReadGroupKubeMQQueueOptions) Reset added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) Reset()

func (*ReadGroupKubeMQQueueOptions) String added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) String() string

func (*ReadGroupKubeMQQueueOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) XXX_DiscardUnknown()

func (*ReadGroupKubeMQQueueOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupKubeMQQueueOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) XXX_Merge(src proto.Message)

func (*ReadGroupKubeMQQueueOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) XXX_Size() int

func (*ReadGroupKubeMQQueueOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) XXX_Unmarshal(b []byte) error

type ReadGroupMQTTOptions added in v0.0.49 

type ReadGroupMQTTOptions struct {
	// @gotags: kong:"embed"
	XConn *args.MQTTConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.MQTTReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ReadGroupMQTTOptions) Descriptor added in v0.0.49 

func (*ReadGroupMQTTOptions) Descriptor() ([]byte, []int)

func (*ReadGroupMQTTOptions) GetArgs added in v0.0.49 

func (m *ReadGroupMQTTOptions) GetArgs() *args.MQTTReadArgs

func (*ReadGroupMQTTOptions) GetXConn added in v0.0.49 

func (m *ReadGroupMQTTOptions) GetXConn() *args.MQTTConn

func (*ReadGroupMQTTOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupMQTTOptions) ProtoMessage()

func (*ReadGroupMQTTOptions) Reset added in v0.0.49 

func (m *ReadGroupMQTTOptions) Reset()

func (*ReadGroupMQTTOptions) String added in v0.0.49 

func (m *ReadGroupMQTTOptions) String() string

func (*ReadGroupMQTTOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupMQTTOptions) XXX_DiscardUnknown()

func (*ReadGroupMQTTOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupMQTTOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupMQTTOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupMQTTOptions) XXX_Merge(src proto.Message)

func (*ReadGroupMQTTOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupMQTTOptions) XXX_Size() int

func (*ReadGroupMQTTOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupMQTTOptions) XXX_Unmarshal(b []byte) error

type ReadGroupMongoOptions added in v0.0.49 

type ReadGroupMongoOptions struct {
	// @gotags: kong:"embed"
	XConn *args.MongoConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.MongoReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ReadGroupMongoOptions) Descriptor added in v0.0.49 

func (*ReadGroupMongoOptions) Descriptor() ([]byte, []int)

func (*ReadGroupMongoOptions) GetArgs added in v0.0.49 

func (m *ReadGroupMongoOptions) GetArgs() *args.MongoReadArgs

func (*ReadGroupMongoOptions) GetXConn added in v0.0.49 

func (m *ReadGroupMongoOptions) GetXConn() *args.MongoConn

func (*ReadGroupMongoOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupMongoOptions) ProtoMessage()

func (*ReadGroupMongoOptions) Reset added in v0.0.49 

func (m *ReadGroupMongoOptions) Reset()

func (*ReadGroupMongoOptions) String added in v0.0.49 

func (m *ReadGroupMongoOptions) String() string

func (*ReadGroupMongoOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupMongoOptions) XXX_DiscardUnknown()

func (*ReadGroupMongoOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupMongoOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupMongoOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupMongoOptions) XXX_Merge(src proto.Message)

func (*ReadGroupMongoOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupMongoOptions) XXX_Size() int

func (*ReadGroupMongoOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupMongoOptions) XXX_Unmarshal(b []byte) error

type ReadGroupNSQOptions added in v0.0.49 

type ReadGroupNSQOptions struct {
	// @gotags: kong:"embed"
	XConn *args.NSQConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.NSQReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ReadGroupNSQOptions) Descriptor added in v0.0.49 

func (*ReadGroupNSQOptions) Descriptor() ([]byte, []int)

func (*ReadGroupNSQOptions) GetArgs added in v0.0.49 

func (m *ReadGroupNSQOptions) GetArgs() *args.NSQReadArgs

func (*ReadGroupNSQOptions) GetXConn added in v0.0.49 

func (m *ReadGroupNSQOptions) GetXConn() *args.NSQConn

func (*ReadGroupNSQOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupNSQOptions) ProtoMessage()

func (*ReadGroupNSQOptions) Reset added in v0.0.49 

func (m *ReadGroupNSQOptions) Reset()

func (*ReadGroupNSQOptions) String added in v0.0.49 

func (m *ReadGroupNSQOptions) String() string

func (*ReadGroupNSQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupNSQOptions) XXX_DiscardUnknown()

func (*ReadGroupNSQOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupNSQOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupNSQOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupNSQOptions) XXX_Merge(src proto.Message)

func (*ReadGroupNSQOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupNSQOptions) XXX_Size() int

func (*ReadGroupNSQOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupNSQOptions) XXX_Unmarshal(b []byte) error

type ReadGroupNatsOptions added in v0.0.49 

type ReadGroupNatsOptions struct {
	// @gotags: kong:"embed"
	XConn *args.NatsConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.NatsReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ReadGroupNatsOptions) Descriptor added in v0.0.49 

func (*ReadGroupNatsOptions) Descriptor() ([]byte, []int)

func (*ReadGroupNatsOptions) GetArgs added in v0.0.49 

func (m *ReadGroupNatsOptions) GetArgs() *args.NatsReadArgs

func (*ReadGroupNatsOptions) GetXConn added in v0.0.49 

func (m *ReadGroupNatsOptions) GetXConn() *args.NatsConn

func (*ReadGroupNatsOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupNatsOptions) ProtoMessage()

func (*ReadGroupNatsOptions) Reset added in v0.0.49 

func (m *ReadGroupNatsOptions) Reset()

func (*ReadGroupNatsOptions) String added in v0.0.49 

func (m *ReadGroupNatsOptions) String() string

func (*ReadGroupNatsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupNatsOptions) XXX_DiscardUnknown()

func (*ReadGroupNatsOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupNatsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupNatsOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupNatsOptions) XXX_Merge(src proto.Message)

func (*ReadGroupNatsOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupNatsOptions) XXX_Size() int

func (*ReadGroupNatsOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupNatsOptions) XXX_Unmarshal(b []byte) error

type ReadGroupNatsStreamingOptions added in v0.0.49 

type ReadGroupNatsStreamingOptions struct {
	// @gotags: kong:"embed"
	XConn *args.NatsStreamingConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.NatsStreamingReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ReadGroupNatsStreamingOptions) Descriptor added in v0.0.49 

func (*ReadGroupNatsStreamingOptions) Descriptor() ([]byte, []int)

func (*ReadGroupNatsStreamingOptions) GetArgs added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) GetArgs() *args.NatsStreamingReadArgs

func (*ReadGroupNatsStreamingOptions) GetXConn added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) GetXConn() *args.NatsStreamingConn

func (*ReadGroupNatsStreamingOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupNatsStreamingOptions) ProtoMessage()

func (*ReadGroupNatsStreamingOptions) Reset added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) Reset()

func (*ReadGroupNatsStreamingOptions) String added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) String() string

func (*ReadGroupNatsStreamingOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) XXX_DiscardUnknown()

func (*ReadGroupNatsStreamingOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupNatsStreamingOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) XXX_Merge(src proto.Message)

func (*ReadGroupNatsStreamingOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) XXX_Size() int

func (*ReadGroupNatsStreamingOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) XXX_Unmarshal(b []byte) error

type ReadGroupPostgresOptions added in v0.0.49 

type ReadGroupPostgresOptions struct {
	// @gotags: kong:"embed"
	XConn *args.PostgresConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.PostgresReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ReadGroupPostgresOptions) Descriptor added in v0.0.49 

func (*ReadGroupPostgresOptions) Descriptor() ([]byte, []int)

func (*ReadGroupPostgresOptions) GetArgs added in v0.0.49 

func (m *ReadGroupPostgresOptions) GetArgs() *args.PostgresReadArgs

func (*ReadGroupPostgresOptions) GetXConn added in v0.0.49 

func (m *ReadGroupPostgresOptions) GetXConn() *args.PostgresConn

func (*ReadGroupPostgresOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupPostgresOptions) ProtoMessage()

func (*ReadGroupPostgresOptions) Reset added in v0.0.49 

func (m *ReadGroupPostgresOptions) Reset()

func (*ReadGroupPostgresOptions) String added in v0.0.49 

func (m *ReadGroupPostgresOptions) String() string

func (*ReadGroupPostgresOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupPostgresOptions) XXX_DiscardUnknown()

func (*ReadGroupPostgresOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupPostgresOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupPostgresOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupPostgresOptions) XXX_Merge(src proto.Message)

func (*ReadGroupPostgresOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupPostgresOptions) XXX_Size() int

func (*ReadGroupPostgresOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupPostgresOptions) XXX_Unmarshal(b []byte) error

type ReadGroupPulsarOptions added in v0.0.49 

type ReadGroupPulsarOptions struct {
	// @gotags: kong:"embed"
	XConn *args.PulsarConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.PulsarReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ReadGroupPulsarOptions) Descriptor added in v0.0.49 

func (*ReadGroupPulsarOptions) Descriptor() ([]byte, []int)

func (*ReadGroupPulsarOptions) GetArgs added in v0.0.49 

func (m *ReadGroupPulsarOptions) GetArgs() *args.PulsarReadArgs

func (*ReadGroupPulsarOptions) GetXConn added in v0.0.49 

func (m *ReadGroupPulsarOptions) GetXConn() *args.PulsarConn

func (*ReadGroupPulsarOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupPulsarOptions) ProtoMessage()

func (*ReadGroupPulsarOptions) Reset added in v0.0.49 

func (m *ReadGroupPulsarOptions) Reset()

func (*ReadGroupPulsarOptions) String added in v0.0.49 

func (m *ReadGroupPulsarOptions) String() string

func (*ReadGroupPulsarOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupPulsarOptions) XXX_DiscardUnknown()

func (*ReadGroupPulsarOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupPulsarOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupPulsarOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupPulsarOptions) XXX_Merge(src proto.Message)

func (*ReadGroupPulsarOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupPulsarOptions) XXX_Size() int

func (*ReadGroupPulsarOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupPulsarOptions) XXX_Unmarshal(b []byte) error

type ReadGroupRabbitOptions added in v0.0.49 

type ReadGroupRabbitOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RabbitConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RabbitReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ReadGroupRabbitOptions) Descriptor added in v0.0.49 

func (*ReadGroupRabbitOptions) Descriptor() ([]byte, []int)

func (*ReadGroupRabbitOptions) GetArgs added in v0.0.49 

func (m *ReadGroupRabbitOptions) GetArgs() *args.RabbitReadArgs

func (*ReadGroupRabbitOptions) GetXConn added in v0.0.49 

func (m *ReadGroupRabbitOptions) GetXConn() *args.RabbitConn

func (*ReadGroupRabbitOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRabbitOptions) ProtoMessage()

func (*ReadGroupRabbitOptions) Reset added in v0.0.49 

func (m *ReadGroupRabbitOptions) Reset()

func (*ReadGroupRabbitOptions) String added in v0.0.49 

func (m *ReadGroupRabbitOptions) String() string

func (*ReadGroupRabbitOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupRabbitOptions) XXX_DiscardUnknown()

func (*ReadGroupRabbitOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupRabbitOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupRabbitOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupRabbitOptions) XXX_Merge(src proto.Message)

func (*ReadGroupRabbitOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupRabbitOptions) XXX_Size() int

func (*ReadGroupRabbitOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupRabbitOptions) XXX_Unmarshal(b []byte) error

type ReadGroupRabbitStreamsOptions added in v0.0.49 

type ReadGroupRabbitStreamsOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RabbitStreamsConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RabbitStreamsReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ReadGroupRabbitStreamsOptions) Descriptor added in v0.0.49 

func (*ReadGroupRabbitStreamsOptions) Descriptor() ([]byte, []int)

func (*ReadGroupRabbitStreamsOptions) GetArgs added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) GetArgs() *args.RabbitStreamsReadArgs

func (*ReadGroupRabbitStreamsOptions) GetXConn added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) GetXConn() *args.RabbitStreamsConn

func (*ReadGroupRabbitStreamsOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRabbitStreamsOptions) ProtoMessage()

func (*ReadGroupRabbitStreamsOptions) Reset added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) Reset()

func (*ReadGroupRabbitStreamsOptions) String added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) String() string

func (*ReadGroupRabbitStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) XXX_DiscardUnknown()

func (*ReadGroupRabbitStreamsOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupRabbitStreamsOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) XXX_Merge(src proto.Message)

func (*ReadGroupRabbitStreamsOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) XXX_Size() int

func (*ReadGroupRabbitStreamsOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) XXX_Unmarshal(b []byte) error

type ReadGroupRedisPubSubOptions added in v0.0.49 

type ReadGroupRedisPubSubOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RedisPubSubConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RedisPubSubReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ReadGroupRedisPubSubOptions) Descriptor added in v0.0.49 

func (*ReadGroupRedisPubSubOptions) Descriptor() ([]byte, []int)

func (*ReadGroupRedisPubSubOptions) GetArgs added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) GetArgs() *args.RedisPubSubReadArgs

func (*ReadGroupRedisPubSubOptions) GetXConn added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) GetXConn() *args.RedisPubSubConn

func (*ReadGroupRedisPubSubOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRedisPubSubOptions) ProtoMessage()

func (*ReadGroupRedisPubSubOptions) Reset added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) Reset()

func (*ReadGroupRedisPubSubOptions) String added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) String() string

func (*ReadGroupRedisPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) XXX_DiscardUnknown()

func (*ReadGroupRedisPubSubOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupRedisPubSubOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) XXX_Merge(src proto.Message)

func (*ReadGroupRedisPubSubOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) XXX_Size() int

func (*ReadGroupRedisPubSubOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) XXX_Unmarshal(b []byte) error

type ReadGroupRedisStreamsOptions added in v0.0.49 

type ReadGroupRedisStreamsOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RedisStreamsConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RedisStreamsReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ReadGroupRedisStreamsOptions) Descriptor added in v0.0.49 

func (*ReadGroupRedisStreamsOptions) Descriptor() ([]byte, []int)

func (*ReadGroupRedisStreamsOptions) GetArgs added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) GetArgs() *args.RedisStreamsReadArgs

func (*ReadGroupRedisStreamsOptions) GetXConn added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) GetXConn() *args.RedisStreamsConn

func (*ReadGroupRedisStreamsOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRedisStreamsOptions) ProtoMessage()

func (*ReadGroupRedisStreamsOptions) Reset added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) Reset()

func (*ReadGroupRedisStreamsOptions) String added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) String() string

func (*ReadGroupRedisStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) XXX_DiscardUnknown()

func (*ReadGroupRedisStreamsOptions) XXX_Marshal added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadGroupRedisStreamsOptions) XXX_Merge added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) XXX_Merge(src proto.Message)

func (*ReadGroupRedisStreamsOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) XXX_Size() int

func (*ReadGroupRedisStreamsOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) XXX_Unmarshal(b []byte) error

type ReadOptions added in v0.0.49 

type ReadOptions struct {
	// Required; friendly name for the read
	// @gotags: kong:"-"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" kong:"-"`
	// Required for desktop; ignored in CLI.
	// @gotags: kong:"-"
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" kong:"-"`
	// Required; specify if a read is continuous or not (default: false)
	// @gotags: short:"f" default: "false"
	Continuous bool `protobuf:"varint,3,opt,name=continuous,proto3" json:"continuous,omitempty" short:"f"`
	// Optional; specify if reading should utilize sampling
	// @gotags: kong:"embed,group=sampling"
	SampleOptions *ReadSampleOptions `` /* 128-byte string literal not displayed */
	// Optional; decode_options specify how to decode the _value_ in a message.
	// If left unset, plumber will still populate records.ReadRecord.Decoded
	// with the (untouched) value.
	// @gotags: kong:"embed,group=decode"
	DecodeOptions *encoding.DecodeOptions `` /* 126-byte string literal not displayed */
	// Automatically set by plumber when a new read is created
	// @gotags: kong:"-"
	XId string `protobuf:"bytes,1000,opt,name=_id,json=Id,proto3" json:"_id,omitempty" kong:"-"`
	// Used by plumber to set read state
	// @gotags: kong:"-"
	XActive bool `protobuf:"varint,1001,opt,name=_active,json=Active,proto3" json:"_active,omitempty" kong:"-"`
	// Contains options/fields specific to the CLI
	// @gotags: kong:"embed"
	XCliOptions *ReadCLIOptions `protobuf:"bytes,1002,opt,name=_cli_options,json=CliOptions,proto3" json:"_cli_options,omitempty" kong:"embed"`
	// @gotags: kong:"cmd,help='Apache Kafka'"
	Kafka *ReadGroupKafkaOptions `protobuf:"bytes,100,opt,name=kafka,proto3" json:"kafka,omitempty" kong:"cmd,help='Apache Kafka'"`
	// @gotags: kong:"cmd,help='Apache ActiveMQ (STOMP)'"
	Activemq *ReadGroupActiveMQOptions `protobuf:"bytes,101,opt,name=activemq,proto3" json:"activemq,omitempty" kong:"cmd,help='Apache ActiveMQ (STOMP)'"`
	// @gotags: kong:"cmd,help='AWS Simple Queue System'"
	Awssqs *ReadGroupAWSSQSOptions `protobuf:"bytes,102,opt,name=awssqs,proto3" json:"awssqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='MongoDB'"
	Mongo *ReadGroupMongoOptions `protobuf:"bytes,103,opt,name=mongo,proto3" json:"mongo,omitempty" kong:"cmd,help='MongoDB'"`
	// @gotags: kong:"cmd,help='NATS'"
	Nats *ReadGroupNatsOptions `protobuf:"bytes,104,opt,name=nats,proto3" json:"nats,omitempty" kong:"cmd,help='NATS'"`
	// @gotags: kong:"cmd,help='NATS Streaming'"
	NatsStreaming *ReadGroupNatsStreamingOptions `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *ReadGroupNSQOptions `protobuf:"bytes,106,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='Apache Pulsar'"
	Pulsar *ReadGroupPulsarOptions `protobuf:"bytes,107,opt,name=pulsar,proto3" json:"pulsar,omitempty" kong:"cmd,help='Apache Pulsar'"`
	// @gotags: kong:"cmd,help='RabbitMQ'"
	Rabbit *ReadGroupRabbitOptions `protobuf:"bytes,108,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='RabbitMQ'"`
	// @gotags: kong:"cmd,help='RabbitMQ Streams'"
	RabbitStreams *ReadGroupRabbitStreamsOptions `` /* 137-byte string literal not displayed */
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *ReadGroupMQTTOptions `protobuf:"bytes,110,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *ReadGroupAzureServiceBusOptions `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help=”"
	AzureEventHub *ReadGroupAzureEventHubOptions `protobuf:"bytes,112,opt,name=azure_event_hub,json=azureEventHub,proto3" json:"azure_event_hub,omitempty" kong:"cmd,help=''"`
	// @gotags: kong:"cmd,help='Google Cloud Platform Pub/Sub'"
	GcpPubsub *ReadGroupGCPPubSubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *ReadGroupKubeMQQueueOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *ReadGroupRedisPubSubOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams *ReadGroupRedisStreamsOptions `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='PostgreSQL'"
	Postgres             *ReadGroupPostgresOptions `protobuf:"bytes,117,opt,name=postgres,proto3" json:"postgres,omitempty" kong:"cmd,help='PostgreSQL'"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

Relay is the structure that backends accept for facilitating a relay.

func (*ReadOptions) Descriptor added in v0.0.49 

func (*ReadOptions) Descriptor() ([]byte, []int)

func (*ReadOptions) GetActivemq added in v0.0.49 

func (m *ReadOptions) GetActivemq() *ReadGroupActiveMQOptions

func (*ReadOptions) GetAwssqs added in v0.0.49 

func (m *ReadOptions) GetAwssqs() *ReadGroupAWSSQSOptions

func (*ReadOptions) GetAzureEventHub added in v0.0.49 

func (m *ReadOptions) GetAzureEventHub() *ReadGroupAzureEventHubOptions

func (*ReadOptions) GetAzureServiceBus added in v0.0.49 

func (m *ReadOptions) GetAzureServiceBus() *ReadGroupAzureServiceBusOptions

func (*ReadOptions) GetConnectionId added in v0.0.49 

func (m *ReadOptions) GetConnectionId() string

func (*ReadOptions) GetContinuous added in v0.0.49 

func (m *ReadOptions) GetContinuous() bool

func (*ReadOptions) GetDecodeOptions added in v0.0.49 

func (m *ReadOptions) GetDecodeOptions() *encoding.DecodeOptions

func (*ReadOptions) GetGcpPubsub added in v0.0.49 

func (m *ReadOptions) GetGcpPubsub() *ReadGroupGCPPubSubOptions

func (*ReadOptions) GetKafka added in v0.0.49 

func (m *ReadOptions) GetKafka() *ReadGroupKafkaOptions

func (*ReadOptions) GetKubemqQueue added in v0.0.49 

func (m *ReadOptions) GetKubemqQueue() *ReadGroupKubeMQQueueOptions

func (*ReadOptions) GetMongo added in v0.0.49 

func (m *ReadOptions) GetMongo() *ReadGroupMongoOptions

func (*ReadOptions) GetMqtt added in v0.0.49 

func (m *ReadOptions) GetMqtt() *ReadGroupMQTTOptions

func (*ReadOptions) GetName added in v0.0.49 

func (m *ReadOptions) GetName() string

func (*ReadOptions) GetNats added in v0.0.49 

func (m *ReadOptions) GetNats() *ReadGroupNatsOptions

func (*ReadOptions) GetNatsStreaming added in v0.0.49 

func (m *ReadOptions) GetNatsStreaming() *ReadGroupNatsStreamingOptions

func (*ReadOptions) GetNsq added in v0.0.49 

func (m *ReadOptions) GetNsq() *ReadGroupNSQOptions

func (*ReadOptions) GetPostgres added in v0.0.49 

func (m *ReadOptions) GetPostgres() *ReadGroupPostgresOptions

func (*ReadOptions) GetPulsar added in v0.0.49 

func (m *ReadOptions) GetPulsar() *ReadGroupPulsarOptions

func (*ReadOptions) GetRabbit added in v0.0.49 

func (m *ReadOptions) GetRabbit() *ReadGroupRabbitOptions

func (*ReadOptions) GetRabbitStreams added in v0.0.49 

func (m *ReadOptions) GetRabbitStreams() *ReadGroupRabbitStreamsOptions

func (*ReadOptions) GetRedisPubsub added in v0.0.49 

func (m *ReadOptions) GetRedisPubsub() *ReadGroupRedisPubSubOptions

func (*ReadOptions) GetRedisStreams added in v0.0.49 

func (m *ReadOptions) GetRedisStreams() *ReadGroupRedisStreamsOptions

func (*ReadOptions) GetSampleOptions added in v0.0.49 

func (m *ReadOptions) GetSampleOptions() *ReadSampleOptions

func (*ReadOptions) GetXActive added in v0.0.49 

func (m *ReadOptions) GetXActive() bool

func (*ReadOptions) GetXCliOptions added in v0.0.49 

func (m *ReadOptions) GetXCliOptions() *ReadCLIOptions

func (*ReadOptions) GetXId added in v0.0.49 

func (m *ReadOptions) GetXId() string

func (*ReadOptions) ProtoMessage added in v0.0.49 

func (*ReadOptions) ProtoMessage()

func (*ReadOptions) Reset added in v0.0.49 

func (m *ReadOptions) Reset()

func (*ReadOptions) String added in v0.0.49 

func (m *ReadOptions) String() string

func (*ReadOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadOptions) XXX_DiscardUnknown()

func (*ReadOptions) XXX_Marshal added in v0.0.49 

func (m *ReadOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadOptions) XXX_Merge added in v0.0.49 

func (m *ReadOptions) XXX_Merge(src proto.Message)

func (*ReadOptions) XXX_Size added in v0.0.49 

func (m *ReadOptions) XXX_Size() int

func (*ReadOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadOptions) XXX_Unmarshal(b []byte) error

type ReadSampleOptions added in v0.0.49 

type ReadSampleOptions struct {
	// @gotags: kong:"help='How many events to fetch during a sample interval',default=100"
	SampleRate uint32 `` /* 168-byte string literal not displayed */
	// @gotags: kong:"help='Sample interval seconds',enum:'1,60',default=60"
	SampleIntervalSeconds uint32   `` /* 188-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*ReadSampleOptions) Descriptor added in v0.0.49 

func (*ReadSampleOptions) Descriptor() ([]byte, []int)

func (*ReadSampleOptions) GetSampleIntervalSeconds added in v0.0.49 

func (m *ReadSampleOptions) GetSampleIntervalSeconds() uint32

func (*ReadSampleOptions) GetSampleRate added in v0.0.49 

func (m *ReadSampleOptions) GetSampleRate() uint32

func (*ReadSampleOptions) ProtoMessage added in v0.0.49 

func (*ReadSampleOptions) ProtoMessage()

func (*ReadSampleOptions) Reset added in v0.0.49 

func (m *ReadSampleOptions) Reset()

func (*ReadSampleOptions) String added in v0.0.49 

func (m *ReadSampleOptions) String() string

func (*ReadSampleOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadSampleOptions) XXX_DiscardUnknown()

func (*ReadSampleOptions) XXX_Marshal added in v0.0.49 

func (m *ReadSampleOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadSampleOptions) XXX_Merge added in v0.0.49 

func (m *ReadSampleOptions) XXX_Merge(src proto.Message)

func (*ReadSampleOptions) XXX_Size added in v0.0.49 

func (m *ReadSampleOptions) XXX_Size() int

func (*ReadSampleOptions) XXX_Unmarshal added in v0.0.49 

func (m *ReadSampleOptions) XXX_Unmarshal(b []byte) error

type RelayCLIOptions added in v0.0.49 

type RelayCLIOptions struct {
	// @gotags: kong:"help='What address to bind the built-in HTTP server to',default='http://localhost:9191'"
	HttpListenAddress    string   `` /* 209-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RelayCLIOptions) Descriptor added in v0.0.49 

func (*RelayCLIOptions) Descriptor() ([]byte, []int)

func (*RelayCLIOptions) GetHttpListenAddress added in v0.0.49 

func (m *RelayCLIOptions) GetHttpListenAddress() string

func (*RelayCLIOptions) ProtoMessage added in v0.0.49 

func (*RelayCLIOptions) ProtoMessage()

func (*RelayCLIOptions) Reset added in v0.0.49 

func (m *RelayCLIOptions) Reset()

func (*RelayCLIOptions) String added in v0.0.49 

func (m *RelayCLIOptions) String() string

func (*RelayCLIOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayCLIOptions) XXX_DiscardUnknown()

func (*RelayCLIOptions) XXX_Marshal added in v0.0.49 

func (m *RelayCLIOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayCLIOptions) XXX_Merge added in v0.0.49 

func (m *RelayCLIOptions) XXX_Merge(src proto.Message)

func (*RelayCLIOptions) XXX_Size added in v0.0.49 

func (m *RelayCLIOptions) XXX_Size() int

func (*RelayCLIOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayCLIOptions) XXX_Unmarshal(b []byte) error

type RelayGroupAWSSQSOptions added in v0.0.49 

type RelayGroupAWSSQSOptions struct {
	// @gotags: kong:"embed"
	XConn *args.AWSSQSConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.AWSSQSRelayArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*RelayGroupAWSSQSOptions) Descriptor added in v0.0.49 

func (*RelayGroupAWSSQSOptions) Descriptor() ([]byte, []int)

func (*RelayGroupAWSSQSOptions) GetArgs added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) GetArgs() *args.AWSSQSRelayArgs

func (*RelayGroupAWSSQSOptions) GetXConn added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) GetXConn() *args.AWSSQSConn

func (*RelayGroupAWSSQSOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupAWSSQSOptions) ProtoMessage()

func (*RelayGroupAWSSQSOptions) Reset added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) Reset()

func (*RelayGroupAWSSQSOptions) String added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) String() string

func (*RelayGroupAWSSQSOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) XXX_DiscardUnknown()

func (*RelayGroupAWSSQSOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupAWSSQSOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) XXX_Merge(src proto.Message)

func (*RelayGroupAWSSQSOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) XXX_Size() int

func (*RelayGroupAWSSQSOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) XXX_Unmarshal(b []byte) error

type RelayGroupAzureServiceBusOptions added in v0.0.49 

type RelayGroupAzureServiceBusOptions struct {
	// @gotags: kong:"embed"
	XConn *args.AzureServiceBusConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.AzureServiceBusReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*RelayGroupAzureServiceBusOptions) Descriptor added in v0.0.49 

func (*RelayGroupAzureServiceBusOptions) Descriptor() ([]byte, []int)

func (*RelayGroupAzureServiceBusOptions) GetArgs added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) GetArgs() *args.AzureServiceBusReadArgs

func (*RelayGroupAzureServiceBusOptions) GetXConn added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) GetXConn() *args.AzureServiceBusConn

func (*RelayGroupAzureServiceBusOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupAzureServiceBusOptions) ProtoMessage()

func (*RelayGroupAzureServiceBusOptions) Reset added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) Reset()

func (*RelayGroupAzureServiceBusOptions) String added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) String() string

func (*RelayGroupAzureServiceBusOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) XXX_DiscardUnknown()

func (*RelayGroupAzureServiceBusOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupAzureServiceBusOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) XXX_Merge(src proto.Message)

func (*RelayGroupAzureServiceBusOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) XXX_Size() int

func (*RelayGroupAzureServiceBusOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) XXX_Unmarshal(b []byte) error

type RelayGroupGCPPubSubOptions added in v0.0.49 

type RelayGroupGCPPubSubOptions struct {
	// @gotags: kong:"embed"
	XConn *args.GCPPubSubConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.GCPPubSubReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*RelayGroupGCPPubSubOptions) Descriptor added in v0.0.49 

func (*RelayGroupGCPPubSubOptions) Descriptor() ([]byte, []int)

func (*RelayGroupGCPPubSubOptions) GetArgs added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) GetArgs() *args.GCPPubSubReadArgs

func (*RelayGroupGCPPubSubOptions) GetXConn added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) GetXConn() *args.GCPPubSubConn

func (*RelayGroupGCPPubSubOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupGCPPubSubOptions) ProtoMessage()

func (*RelayGroupGCPPubSubOptions) Reset added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) Reset()

func (*RelayGroupGCPPubSubOptions) String added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) String() string

func (*RelayGroupGCPPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) XXX_DiscardUnknown()

func (*RelayGroupGCPPubSubOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupGCPPubSubOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) XXX_Merge(src proto.Message)

func (*RelayGroupGCPPubSubOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) XXX_Size() int

func (*RelayGroupGCPPubSubOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) XXX_Unmarshal(b []byte) error

type RelayGroupKafkaOptions added in v0.0.49 

type RelayGroupKafkaOptions struct {
	// @gotags: kong:"embed"
	XConn *args.KafkaConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.KafkaRelayArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RelayGroupKafkaOptions) Descriptor added in v0.0.49 

func (*RelayGroupKafkaOptions) Descriptor() ([]byte, []int)

func (*RelayGroupKafkaOptions) GetArgs added in v0.0.49 

func (m *RelayGroupKafkaOptions) GetArgs() *args.KafkaRelayArgs

func (*RelayGroupKafkaOptions) GetXConn added in v0.0.49 

func (m *RelayGroupKafkaOptions) GetXConn() *args.KafkaConn

func (*RelayGroupKafkaOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupKafkaOptions) ProtoMessage()

func (*RelayGroupKafkaOptions) Reset added in v0.0.49 

func (m *RelayGroupKafkaOptions) Reset()

func (*RelayGroupKafkaOptions) String added in v0.0.49 

func (m *RelayGroupKafkaOptions) String() string

func (*RelayGroupKafkaOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupKafkaOptions) XXX_DiscardUnknown()

func (*RelayGroupKafkaOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupKafkaOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupKafkaOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupKafkaOptions) XXX_Merge(src proto.Message)

func (*RelayGroupKafkaOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupKafkaOptions) XXX_Size() int

func (*RelayGroupKafkaOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupKafkaOptions) XXX_Unmarshal(b []byte) error

type RelayGroupKubeMQQueueOptions added in v0.0.49 

type RelayGroupKubeMQQueueOptions struct {
	// @gotags: kong:"embed"
	XConn *args.KubeMQQueueConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.KubeMQQueueReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*RelayGroupKubeMQQueueOptions) Descriptor added in v0.0.49 

func (*RelayGroupKubeMQQueueOptions) Descriptor() ([]byte, []int)

func (*RelayGroupKubeMQQueueOptions) GetArgs added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) GetArgs() *args.KubeMQQueueReadArgs

func (*RelayGroupKubeMQQueueOptions) GetXConn added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) GetXConn() *args.KubeMQQueueConn

func (*RelayGroupKubeMQQueueOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupKubeMQQueueOptions) ProtoMessage()

func (*RelayGroupKubeMQQueueOptions) Reset added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) Reset()

func (*RelayGroupKubeMQQueueOptions) String added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) String() string

func (*RelayGroupKubeMQQueueOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) XXX_DiscardUnknown()

func (*RelayGroupKubeMQQueueOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupKubeMQQueueOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) XXX_Merge(src proto.Message)

func (*RelayGroupKubeMQQueueOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) XXX_Size() int

func (*RelayGroupKubeMQQueueOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) XXX_Unmarshal(b []byte) error

type RelayGroupMQTTOptions added in v0.0.49 

type RelayGroupMQTTOptions struct {
	// @gotags: kong:"embed"
	XConn *args.MQTTConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.MQTTReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*RelayGroupMQTTOptions) Descriptor added in v0.0.49 

func (*RelayGroupMQTTOptions) Descriptor() ([]byte, []int)

func (*RelayGroupMQTTOptions) GetArgs added in v0.0.49 

func (m *RelayGroupMQTTOptions) GetArgs() *args.MQTTReadArgs

func (*RelayGroupMQTTOptions) GetXConn added in v0.0.49 

func (m *RelayGroupMQTTOptions) GetXConn() *args.MQTTConn

func (*RelayGroupMQTTOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupMQTTOptions) ProtoMessage()

func (*RelayGroupMQTTOptions) Reset added in v0.0.49 

func (m *RelayGroupMQTTOptions) Reset()

func (*RelayGroupMQTTOptions) String added in v0.0.49 

func (m *RelayGroupMQTTOptions) String() string

func (*RelayGroupMQTTOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupMQTTOptions) XXX_DiscardUnknown()

func (*RelayGroupMQTTOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupMQTTOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupMQTTOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupMQTTOptions) XXX_Merge(src proto.Message)

func (*RelayGroupMQTTOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupMQTTOptions) XXX_Size() int

func (*RelayGroupMQTTOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupMQTTOptions) XXX_Unmarshal(b []byte) error

type RelayGroupMongoOptions added in v0.0.49 

type RelayGroupMongoOptions struct {
	// @gotags: kong:"embed"
	XConn *args.MongoConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.MongoReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RelayGroupMongoOptions) Descriptor added in v0.0.49 

func (*RelayGroupMongoOptions) Descriptor() ([]byte, []int)

func (*RelayGroupMongoOptions) GetArgs added in v0.0.49 

func (m *RelayGroupMongoOptions) GetArgs() *args.MongoReadArgs

func (*RelayGroupMongoOptions) GetXConn added in v0.0.49 

func (m *RelayGroupMongoOptions) GetXConn() *args.MongoConn

func (*RelayGroupMongoOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupMongoOptions) ProtoMessage()

func (*RelayGroupMongoOptions) Reset added in v0.0.49 

func (m *RelayGroupMongoOptions) Reset()

func (*RelayGroupMongoOptions) String added in v0.0.49 

func (m *RelayGroupMongoOptions) String() string

func (*RelayGroupMongoOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupMongoOptions) XXX_DiscardUnknown()

func (*RelayGroupMongoOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupMongoOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupMongoOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupMongoOptions) XXX_Merge(src proto.Message)

func (*RelayGroupMongoOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupMongoOptions) XXX_Size() int

func (*RelayGroupMongoOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupMongoOptions) XXX_Unmarshal(b []byte) error

type RelayGroupNSQOptions added in v0.0.49 

type RelayGroupNSQOptions struct {
	// @gotags: kong:"embed"
	XConn *args.NSQConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.NSQReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RelayGroupNSQOptions) Descriptor added in v0.0.49 

func (*RelayGroupNSQOptions) Descriptor() ([]byte, []int)

func (*RelayGroupNSQOptions) GetArgs added in v0.0.49 

func (m *RelayGroupNSQOptions) GetArgs() *args.NSQReadArgs

func (*RelayGroupNSQOptions) GetXConn added in v0.0.49 

func (m *RelayGroupNSQOptions) GetXConn() *args.NSQConn

func (*RelayGroupNSQOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupNSQOptions) ProtoMessage()

func (*RelayGroupNSQOptions) Reset added in v0.0.49 

func (m *RelayGroupNSQOptions) Reset()

func (*RelayGroupNSQOptions) String added in v0.0.49 

func (m *RelayGroupNSQOptions) String() string

func (*RelayGroupNSQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupNSQOptions) XXX_DiscardUnknown()

func (*RelayGroupNSQOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupNSQOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupNSQOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupNSQOptions) XXX_Merge(src proto.Message)

func (*RelayGroupNSQOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupNSQOptions) XXX_Size() int

func (*RelayGroupNSQOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupNSQOptions) XXX_Unmarshal(b []byte) error

type RelayGroupPostgresOptions added in v0.0.49 

type RelayGroupPostgresOptions struct {
	// @gotags: kong:"embed"
	XConn *args.PostgresConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.PostgresReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*RelayGroupPostgresOptions) Descriptor added in v0.0.49 

func (*RelayGroupPostgresOptions) Descriptor() ([]byte, []int)

func (*RelayGroupPostgresOptions) GetArgs added in v0.0.49 

func (m *RelayGroupPostgresOptions) GetArgs() *args.PostgresReadArgs

func (*RelayGroupPostgresOptions) GetXConn added in v0.0.49 

func (m *RelayGroupPostgresOptions) GetXConn() *args.PostgresConn

func (*RelayGroupPostgresOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupPostgresOptions) ProtoMessage()

func (*RelayGroupPostgresOptions) Reset added in v0.0.49 

func (m *RelayGroupPostgresOptions) Reset()

func (*RelayGroupPostgresOptions) String added in v0.0.49 

func (m *RelayGroupPostgresOptions) String() string

func (*RelayGroupPostgresOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupPostgresOptions) XXX_DiscardUnknown()

func (*RelayGroupPostgresOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupPostgresOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupPostgresOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupPostgresOptions) XXX_Merge(src proto.Message)

func (*RelayGroupPostgresOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupPostgresOptions) XXX_Size() int

func (*RelayGroupPostgresOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupPostgresOptions) XXX_Unmarshal(b []byte) error

type RelayGroupRabbitOptions added in v0.0.49 

type RelayGroupRabbitOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RabbitConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RabbitReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RelayGroupRabbitOptions) Descriptor added in v0.0.49 

func (*RelayGroupRabbitOptions) Descriptor() ([]byte, []int)

func (*RelayGroupRabbitOptions) GetArgs added in v0.0.49 

func (m *RelayGroupRabbitOptions) GetArgs() *args.RabbitReadArgs

func (*RelayGroupRabbitOptions) GetXConn added in v0.0.49 

func (m *RelayGroupRabbitOptions) GetXConn() *args.RabbitConn

func (*RelayGroupRabbitOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupRabbitOptions) ProtoMessage()

func (*RelayGroupRabbitOptions) Reset added in v0.0.49 

func (m *RelayGroupRabbitOptions) Reset()

func (*RelayGroupRabbitOptions) String added in v0.0.49 

func (m *RelayGroupRabbitOptions) String() string

func (*RelayGroupRabbitOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupRabbitOptions) XXX_DiscardUnknown()

func (*RelayGroupRabbitOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupRabbitOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupRabbitOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupRabbitOptions) XXX_Merge(src proto.Message)

func (*RelayGroupRabbitOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupRabbitOptions) XXX_Size() int

func (*RelayGroupRabbitOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupRabbitOptions) XXX_Unmarshal(b []byte) error

type RelayGroupRedisPubSubOptions added in v0.0.49 

type RelayGroupRedisPubSubOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RedisPubSubConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RedisPubSubReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*RelayGroupRedisPubSubOptions) Descriptor added in v0.0.49 

func (*RelayGroupRedisPubSubOptions) Descriptor() ([]byte, []int)

func (*RelayGroupRedisPubSubOptions) GetArgs added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) GetArgs() *args.RedisPubSubReadArgs

func (*RelayGroupRedisPubSubOptions) GetXConn added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) GetXConn() *args.RedisPubSubConn

func (*RelayGroupRedisPubSubOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupRedisPubSubOptions) ProtoMessage()

func (*RelayGroupRedisPubSubOptions) Reset added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) Reset()

func (*RelayGroupRedisPubSubOptions) String added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) String() string

func (*RelayGroupRedisPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) XXX_DiscardUnknown()

func (*RelayGroupRedisPubSubOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupRedisPubSubOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) XXX_Merge(src proto.Message)

func (*RelayGroupRedisPubSubOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) XXX_Size() int

func (*RelayGroupRedisPubSubOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) XXX_Unmarshal(b []byte) error

type RelayGroupRedisStreamsOptions added in v0.0.49 

type RelayGroupRedisStreamsOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RedisStreamsConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RedisStreamsReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*RelayGroupRedisStreamsOptions) Descriptor added in v0.0.49 

func (*RelayGroupRedisStreamsOptions) Descriptor() ([]byte, []int)

func (*RelayGroupRedisStreamsOptions) GetArgs added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) GetArgs() *args.RedisStreamsReadArgs

func (*RelayGroupRedisStreamsOptions) GetXConn added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) GetXConn() *args.RedisStreamsConn

func (*RelayGroupRedisStreamsOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupRedisStreamsOptions) ProtoMessage()

func (*RelayGroupRedisStreamsOptions) Reset added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) Reset()

func (*RelayGroupRedisStreamsOptions) String added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) String() string

func (*RelayGroupRedisStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) XXX_DiscardUnknown()

func (*RelayGroupRedisStreamsOptions) XXX_Marshal added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayGroupRedisStreamsOptions) XXX_Merge added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) XXX_Merge(src proto.Message)

func (*RelayGroupRedisStreamsOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) XXX_Size() int

func (*RelayGroupRedisStreamsOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) XXX_Unmarshal(b []byte) error

type RelayOptions added in v0.0.49 

type RelayOptions struct {
	// @gotags: kong:"help='Secret collection token',name=token,required"
	CollectionToken string `` /* 164-byte string literal not displayed */
	// @gotags: kong:"help='How many messages to send in a single batch',default=1000"
	BatchSize int32 `` /* 160-byte string literal not displayed */
	// @gotags: kong:"help='How many times plumber will try re-sending a batch',default=3"
	BatchMaxRetry int32 `` /* 178-byte string literal not displayed */
	// Required for desktop; ignored in CLI.
	// @gotags: kong:"-"
	ConnectionId string `protobuf:"bytes,4,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" kong:"-"`
	// @gotags: kong:"name='How many workers to launch per relay',default=10"
	NumWorkers int32 `` /* 154-byte string literal not displayed */
	// @gotags: kong:"help='Alternative collector to relay events to',name='grpc-address',default='grpc-collector.batch.sh:9000'"
	XBatchshGrpcAddress string `` /* 236-byte string literal not displayed */
	// @gotags: kong:"help='Whether to use TLS with collector',name=grpc-disable-tls,default=true"
	XBatchshGrpcDisableTls bool `` /* 217-byte string literal not displayed */
	// @gotags: kong:"help='How long to wait before giving up talking to the gRPC collector',name='grpc-timeout-seconds'"
	XBatchshGrpcTimeoutSeconds int32 `` /* 252-byte string literal not displayed */
	// ID of the created relay entry; populated by plumber.
	// @gotags: kong:"-"
	XRelayId string `protobuf:"bytes,1003,opt,name=_relay_id,json=RelayId,proto3" json:"_relay_id,omitempty" kong:"-"`
	// @gotags: kong:"embed"
	XCliOptions *RelayCLIOptions `protobuf:"bytes,1004,opt,name=_cli_options,json=CliOptions,proto3" json:"_cli_options,omitempty" kong:"embed"`
	// @gotags: kong:"cmd,help='Apache Kafka'"
	Kafka *RelayGroupKafkaOptions `protobuf:"bytes,100,opt,name=kafka,proto3" json:"kafka,omitempty" kong:"cmd,help='Apache Kafka'"`
	// @gotags: kong:"cmd,help='AWS Simple Queue System'"
	Awssqs *RelayGroupAWSSQSOptions `protobuf:"bytes,101,opt,name=awssqs,proto3" json:"awssqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='MongoDB (CDC)'"
	Mongo *RelayGroupMongoOptions `protobuf:"bytes,102,opt,name=mongo,proto3" json:"mongo,omitempty" kong:"cmd,help='MongoDB (CDC)'"`
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *RelayGroupNSQOptions `protobuf:"bytes,103,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='MQTT'"
	Rabbit *RelayGroupRabbitOptions `protobuf:"bytes,104,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *RelayGroupMQTTOptions `protobuf:"bytes,105,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *RelayGroupAzureServiceBusOptions `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Google Cloud Platform Pub/Sub'"
	GcpPubsub *RelayGroupGCPPubSubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *RelayGroupKubeMQQueueOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *RelayGroupRedisPubSubOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams *RelayGroupRedisStreamsOptions `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='PostgreSQL (CDC)'"
	Postgres             *RelayGroupPostgresOptions `protobuf:"bytes,112,opt,name=postgres,proto3" json:"postgres,omitempty" kong:"cmd,help='PostgreSQL (CDC)'"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Relay is the structure that backends accept for facilitating a relay. NOTE: _conn is only used by the CLI - desktop does not need to set it.

func (*RelayOptions) Descriptor added in v0.0.49 

func (*RelayOptions) Descriptor() ([]byte, []int)

func (*RelayOptions) GetAwssqs added in v0.0.49 

func (m *RelayOptions) GetAwssqs() *RelayGroupAWSSQSOptions

func (*RelayOptions) GetAzureServiceBus added in v0.0.49 

func (m *RelayOptions) GetAzureServiceBus() *RelayGroupAzureServiceBusOptions

func (*RelayOptions) GetBatchMaxRetry added in v0.0.49 

func (m *RelayOptions) GetBatchMaxRetry() int32

func (*RelayOptions) GetBatchSize added in v0.0.49 

func (m *RelayOptions) GetBatchSize() int32

func (*RelayOptions) GetCollectionToken added in v0.0.49 

func (m *RelayOptions) GetCollectionToken() string

func (*RelayOptions) GetConnectionId added in v0.0.49 

func (m *RelayOptions) GetConnectionId() string

func (*RelayOptions) GetGcpPubsub added in v0.0.49 

func (m *RelayOptions) GetGcpPubsub() *RelayGroupGCPPubSubOptions

func (*RelayOptions) GetKafka added in v0.0.49 

func (m *RelayOptions) GetKafka() *RelayGroupKafkaOptions

func (*RelayOptions) GetKubemqQueue added in v0.0.49 

func (m *RelayOptions) GetKubemqQueue() *RelayGroupKubeMQQueueOptions

func (*RelayOptions) GetMongo added in v0.0.49 

func (m *RelayOptions) GetMongo() *RelayGroupMongoOptions

func (*RelayOptions) GetMqtt added in v0.0.49 

func (m *RelayOptions) GetMqtt() *RelayGroupMQTTOptions

func (*RelayOptions) GetNsq added in v0.0.49 

func (m *RelayOptions) GetNsq() *RelayGroupNSQOptions

func (*RelayOptions) GetNumWorkers added in v0.0.49 

func (m *RelayOptions) GetNumWorkers() int32

func (*RelayOptions) GetPostgres added in v0.0.49 

func (m *RelayOptions) GetPostgres() *RelayGroupPostgresOptions

func (*RelayOptions) GetRabbit added in v0.0.49 

func (m *RelayOptions) GetRabbit() *RelayGroupRabbitOptions

func (*RelayOptions) GetRedisPubsub added in v0.0.49 

func (m *RelayOptions) GetRedisPubsub() *RelayGroupRedisPubSubOptions

func (*RelayOptions) GetRedisStreams added in v0.0.49 

func (m *RelayOptions) GetRedisStreams() *RelayGroupRedisStreamsOptions

func (*RelayOptions) GetXBatchshGrpcAddress added in v0.0.49 

func (m *RelayOptions) GetXBatchshGrpcAddress() string

func (*RelayOptions) GetXBatchshGrpcDisableTls added in v0.0.49 

func (m *RelayOptions) GetXBatchshGrpcDisableTls() bool

func (*RelayOptions) GetXBatchshGrpcTimeoutSeconds added in v0.0.49 

func (m *RelayOptions) GetXBatchshGrpcTimeoutSeconds() int32

func (*RelayOptions) GetXCliOptions added in v0.0.49 

func (m *RelayOptions) GetXCliOptions() *RelayCLIOptions

func (*RelayOptions) GetXRelayId added in v0.0.49 

func (m *RelayOptions) GetXRelayId() string

func (*RelayOptions) ProtoMessage added in v0.0.49 

func (*RelayOptions) ProtoMessage()

func (*RelayOptions) Reset added in v0.0.49 

func (m *RelayOptions) Reset()

func (*RelayOptions) String added in v0.0.49 

func (m *RelayOptions) String() string

func (*RelayOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayOptions) XXX_DiscardUnknown()

func (*RelayOptions) XXX_Marshal added in v0.0.49 

func (m *RelayOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayOptions) XXX_Merge added in v0.0.49 

func (m *RelayOptions) XXX_Merge(src proto.Message)

func (*RelayOptions) XXX_Size added in v0.0.49 

func (m *RelayOptions) XXX_Size() int

func (*RelayOptions) XXX_Unmarshal added in v0.0.49 

func (m *RelayOptions) XXX_Unmarshal(b []byte) error

type ServerOptions added in v0.0.49 

type ServerOptions struct {
	// @gotags: kong:"help='Unique ID that identifies this plumber node',env='PLUMBER_SERVER_NODE_ID',required"
	NodeId string `` /* 175-byte string literal not displayed */
	// @gotags: kong:"help='ID of the plumber cluster (has to be the same across all nodes)',env='PLUMBER_SERVER_CLUSTER_ID',required"
	ClusterId string `` /* 207-byte string literal not displayed */
	// @gotags: kong:"help='Host:port that the gRPC server will bind to',env='PLUMBER_SERVER_GRPC_LISTEN_ADDRESS',default=127.0.0.1:9000"
	GrpcListenAddress string `` /* 236-byte string literal not displayed */
	// @gotags: kong:"help='All gRPC requests require this auth token to be set',env='PLUMBER_SERVER_AUTH_TOKEN',required"
	AuthToken string `` /* 195-byte string literal not displayed */
	// @gotags: kong:"help='InitialCluster should contain comma separated list of key=value pairs of host:port entries for ALL peers in the cluster. (Example: server1=http://192.168.1.10:2380,server2=http://192.168.1.11:2380,server3=http://192.168.1.12:2380). IMPORTANT! The list should include the address of _this_ instance.',env='PLUMBER_SERVER_INITIAL_CLUSTER',required"
	InitialCluster string `` /* 462-byte string literal not displayed */
	// @gotags: kong:"help='Address of _this_ plumber instance etcd server interface. Example: http://local-ip:2380',env='PLUMBER_SERVER_ADVERTISE_PEER_URL'"
	AdvertisePeerUrl string `` /* 253-byte string literal not displayed */
	// @gotags: kong:"help='Address of _this_ plumber instance etcd client interface. Example: http://local-ip:2379',env='PLUMBER_SERVER_ADVERTISE_CLIENT_URL',required"
	AdvertiseClientUrl string `` /* 270-byte string literal not displayed */
	// @gotags: kong:"help='Address that _this_ plumber instance etcd server should listen on. Example: http://local-ip:2380',env='PLUMBER_SERVER_LISTENER_PEER_URL'"
	ListenerPeerUrl string `` /* 258-byte string literal not displayed */
	// @gotags: kong:"help='Address that _this_ plumber instance etcd client should listen on. Example: http://local-ip:2379',env='PLUMBER_SERVER_LISTENER_CLIENT_URL'"
	ListenerClientUrl string `` /* 266-byte string literal not displayed */
	// @gotags: kong:"help='Secret token that ALL cluster members should use/share. If this token does not match on one of the plumber instances, this node will NOT be able to join the cluster.',env='PLUMBER_SERVER_PEER_TOKEN'"
	PeerToken            string   `` /* 301-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerOptions) Descriptor added in v0.0.49 

func (*ServerOptions) Descriptor() ([]byte, []int)

func (*ServerOptions) GetAdvertiseClientUrl added in v0.0.49 

func (m *ServerOptions) GetAdvertiseClientUrl() string

func (*ServerOptions) GetAdvertisePeerUrl added in v0.0.49 

func (m *ServerOptions) GetAdvertisePeerUrl() string

func (*ServerOptions) GetAuthToken added in v0.0.49 

func (m *ServerOptions) GetAuthToken() string

func (*ServerOptions) GetClusterId added in v0.0.49 

func (m *ServerOptions) GetClusterId() string

func (*ServerOptions) GetGrpcListenAddress added in v0.0.49 

func (m *ServerOptions) GetGrpcListenAddress() string

func (*ServerOptions) GetInitialCluster added in v0.0.49 

func (m *ServerOptions) GetInitialCluster() string

func (*ServerOptions) GetListenerClientUrl added in v0.0.49 

func (m *ServerOptions) GetListenerClientUrl() string

func (*ServerOptions) GetListenerPeerUrl added in v0.0.49 

func (m *ServerOptions) GetListenerPeerUrl() string

func (*ServerOptions) GetNodeId added in v0.0.49 

func (m *ServerOptions) GetNodeId() string

func (*ServerOptions) GetPeerToken added in v0.0.49 

func (m *ServerOptions) GetPeerToken() string

func (*ServerOptions) ProtoMessage added in v0.0.49 

func (*ServerOptions) ProtoMessage()

func (*ServerOptions) Reset added in v0.0.49 

func (m *ServerOptions) Reset()

func (*ServerOptions) String added in v0.0.49 

func (m *ServerOptions) String() string

func (*ServerOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ServerOptions) XXX_DiscardUnknown()

func (*ServerOptions) XXX_Marshal added in v0.0.49 

func (m *ServerOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerOptions) XXX_Merge added in v0.0.49 

func (m *ServerOptions) XXX_Merge(src proto.Message)

func (*ServerOptions) XXX_Size added in v0.0.49 

func (m *ServerOptions) XXX_Size() int

func (*ServerOptions) XXX_Unmarshal added in v0.0.49 

func (m *ServerOptions) XXX_Unmarshal(b []byte) error

type WriteCLIOptions added in v0.0.49 

type WriteCLIOptions struct {
	// @gotags: kong:"help='Write data from input file',existingfile,xor=input"
	InputFile string `` /* 152-byte string literal not displayed */
	// @gotags: kong="help='Treat input as JSON array - each array element will be written as a separate message'"
	InputAsJsonArray     bool     `protobuf:"varint,2,opt,name=input_as_json_array,json=inputAsJsonArray,proto3" json:"input_as_json_array,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteCLIOptions) Descriptor added in v0.0.49 

func (*WriteCLIOptions) Descriptor() ([]byte, []int)

func (*WriteCLIOptions) GetInputAsJsonArray added in v0.0.49 

func (m *WriteCLIOptions) GetInputAsJsonArray() bool

func (*WriteCLIOptions) GetInputFile added in v0.0.49 

func (m *WriteCLIOptions) GetInputFile() string

func (*WriteCLIOptions) ProtoMessage added in v0.0.49 

func (*WriteCLIOptions) ProtoMessage()

func (*WriteCLIOptions) Reset added in v0.0.49 

func (m *WriteCLIOptions) Reset()

func (*WriteCLIOptions) String added in v0.0.49 

func (m *WriteCLIOptions) String() string

func (*WriteCLIOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteCLIOptions) XXX_DiscardUnknown()

func (*WriteCLIOptions) XXX_Marshal added in v0.0.49 

func (m *WriteCLIOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteCLIOptions) XXX_Merge added in v0.0.49 

func (m *WriteCLIOptions) XXX_Merge(src proto.Message)

func (*WriteCLIOptions) XXX_Size added in v0.0.49 

func (m *WriteCLIOptions) XXX_Size() int

func (*WriteCLIOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteCLIOptions) XXX_Unmarshal(b []byte) error

type WriteGroupAWSSNSOptions added in v0.0.49 

type WriteGroupAWSSNSOptions struct {
	// @gotags: kong:"embed"
	XConn *args.AWSSNSConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.AWSSNSWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*WriteGroupAWSSNSOptions) Descriptor added in v0.0.49 

func (*WriteGroupAWSSNSOptions) Descriptor() ([]byte, []int)

func (*WriteGroupAWSSNSOptions) GetArgs added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) GetArgs() *args.AWSSNSWriteArgs

func (*WriteGroupAWSSNSOptions) GetXConn added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) GetXConn() *args.AWSSNSConn

func (*WriteGroupAWSSNSOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAWSSNSOptions) ProtoMessage()

func (*WriteGroupAWSSNSOptions) Reset added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) Reset()

func (*WriteGroupAWSSNSOptions) String added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) String() string

func (*WriteGroupAWSSNSOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) XXX_DiscardUnknown()

func (*WriteGroupAWSSNSOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupAWSSNSOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) XXX_Merge(src proto.Message)

func (*WriteGroupAWSSNSOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) XXX_Size() int

func (*WriteGroupAWSSNSOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) XXX_Unmarshal(b []byte) error

type WriteGroupAWSSQSOptions added in v0.0.49 

type WriteGroupAWSSQSOptions struct {
	// @gotags: kong:"embed"
	XConn *args.AWSSQSConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.AWSSQSWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*WriteGroupAWSSQSOptions) Descriptor added in v0.0.49 

func (*WriteGroupAWSSQSOptions) Descriptor() ([]byte, []int)

func (*WriteGroupAWSSQSOptions) GetArgs added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) GetArgs() *args.AWSSQSWriteArgs

func (*WriteGroupAWSSQSOptions) GetXConn added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) GetXConn() *args.AWSSQSConn

func (*WriteGroupAWSSQSOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAWSSQSOptions) ProtoMessage()

func (*WriteGroupAWSSQSOptions) Reset added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) Reset()

func (*WriteGroupAWSSQSOptions) String added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) String() string

func (*WriteGroupAWSSQSOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) XXX_DiscardUnknown()

func (*WriteGroupAWSSQSOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupAWSSQSOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) XXX_Merge(src proto.Message)

func (*WriteGroupAWSSQSOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) XXX_Size() int

func (*WriteGroupAWSSQSOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) XXX_Unmarshal(b []byte) error

type WriteGroupActiveMQOptions added in v0.0.49 

type WriteGroupActiveMQOptions struct {
	// @gotags: kong:"embed"
	XConn *args.ActiveMQConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.ActiveMQWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*WriteGroupActiveMQOptions) Descriptor added in v0.0.49 

func (*WriteGroupActiveMQOptions) Descriptor() ([]byte, []int)

func (*WriteGroupActiveMQOptions) GetArgs added in v0.0.49 

func (m *WriteGroupActiveMQOptions) GetArgs() *args.ActiveMQWriteArgs

func (*WriteGroupActiveMQOptions) GetXConn added in v0.0.49 

func (m *WriteGroupActiveMQOptions) GetXConn() *args.ActiveMQConn

func (*WriteGroupActiveMQOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupActiveMQOptions) ProtoMessage()

func (*WriteGroupActiveMQOptions) Reset added in v0.0.49 

func (m *WriteGroupActiveMQOptions) Reset()

func (*WriteGroupActiveMQOptions) String added in v0.0.49 

func (m *WriteGroupActiveMQOptions) String() string

func (*WriteGroupActiveMQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupActiveMQOptions) XXX_DiscardUnknown()

func (*WriteGroupActiveMQOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupActiveMQOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupActiveMQOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupActiveMQOptions) XXX_Merge(src proto.Message)

func (*WriteGroupActiveMQOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupActiveMQOptions) XXX_Size() int

func (*WriteGroupActiveMQOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupActiveMQOptions) XXX_Unmarshal(b []byte) error

type WriteGroupAzureEventHubOptions added in v0.0.49 

type WriteGroupAzureEventHubOptions struct {
	// @gotags: kong:"embed"
	XConn *args.AzureEventHubConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.AzureEventHubWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*WriteGroupAzureEventHubOptions) Descriptor added in v0.0.49 

func (*WriteGroupAzureEventHubOptions) Descriptor() ([]byte, []int)

func (*WriteGroupAzureEventHubOptions) GetArgs added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) GetArgs() *args.AzureEventHubWriteArgs

func (*WriteGroupAzureEventHubOptions) GetXConn added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) GetXConn() *args.AzureEventHubConn

func (*WriteGroupAzureEventHubOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAzureEventHubOptions) ProtoMessage()

func (*WriteGroupAzureEventHubOptions) Reset added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) Reset()

func (*WriteGroupAzureEventHubOptions) String added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) String() string

func (*WriteGroupAzureEventHubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) XXX_DiscardUnknown()

func (*WriteGroupAzureEventHubOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupAzureEventHubOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) XXX_Merge(src proto.Message)

func (*WriteGroupAzureEventHubOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) XXX_Size() int

func (*WriteGroupAzureEventHubOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) XXX_Unmarshal(b []byte) error

type WriteGroupAzureServiceBusOptions added in v0.0.49 

type WriteGroupAzureServiceBusOptions struct {
	// @gotags: kong:"embed"{
	XConn *args.AzureServiceBusConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.AzureServiceBusWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*WriteGroupAzureServiceBusOptions) Descriptor added in v0.0.49 

func (*WriteGroupAzureServiceBusOptions) Descriptor() ([]byte, []int)

func (*WriteGroupAzureServiceBusOptions) GetArgs added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) GetArgs() *args.AzureServiceBusWriteArgs

func (*WriteGroupAzureServiceBusOptions) GetXConn added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) GetXConn() *args.AzureServiceBusConn

func (*WriteGroupAzureServiceBusOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAzureServiceBusOptions) ProtoMessage()

func (*WriteGroupAzureServiceBusOptions) Reset added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) Reset()

func (*WriteGroupAzureServiceBusOptions) String added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) String() string

func (*WriteGroupAzureServiceBusOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) XXX_DiscardUnknown()

func (*WriteGroupAzureServiceBusOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupAzureServiceBusOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) XXX_Merge(src proto.Message)

func (*WriteGroupAzureServiceBusOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) XXX_Size() int

func (*WriteGroupAzureServiceBusOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) XXX_Unmarshal(b []byte) error

type WriteGroupGCPPubSubOptions added in v0.0.49 

type WriteGroupGCPPubSubOptions struct {
	// @gotags: kong:"embed"
	XConn *args.GCPPubSubConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.GCPPubSubWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*WriteGroupGCPPubSubOptions) Descriptor added in v0.0.49 

func (*WriteGroupGCPPubSubOptions) Descriptor() ([]byte, []int)

func (*WriteGroupGCPPubSubOptions) GetArgs added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) GetArgs() *args.GCPPubSubWriteArgs

func (*WriteGroupGCPPubSubOptions) GetXConn added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) GetXConn() *args.GCPPubSubConn

func (*WriteGroupGCPPubSubOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupGCPPubSubOptions) ProtoMessage()

func (*WriteGroupGCPPubSubOptions) Reset added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) Reset()

func (*WriteGroupGCPPubSubOptions) String added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) String() string

func (*WriteGroupGCPPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) XXX_DiscardUnknown()

func (*WriteGroupGCPPubSubOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupGCPPubSubOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) XXX_Merge(src proto.Message)

func (*WriteGroupGCPPubSubOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) XXX_Size() int

func (*WriteGroupGCPPubSubOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) XXX_Unmarshal(b []byte) error

type WriteGroupKafkaOptions added in v0.0.49 

type WriteGroupKafkaOptions struct {
	// @gotags: kong:"embed"
	XConn *args.KafkaConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.KafkaWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*WriteGroupKafkaOptions) Descriptor added in v0.0.49 

func (*WriteGroupKafkaOptions) Descriptor() ([]byte, []int)

func (*WriteGroupKafkaOptions) GetArgs added in v0.0.49 

func (m *WriteGroupKafkaOptions) GetArgs() *args.KafkaWriteArgs

func (*WriteGroupKafkaOptions) GetXConn added in v0.0.49 

func (m *WriteGroupKafkaOptions) GetXConn() *args.KafkaConn

func (*WriteGroupKafkaOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupKafkaOptions) ProtoMessage()

func (*WriteGroupKafkaOptions) Reset added in v0.0.49 

func (m *WriteGroupKafkaOptions) Reset()

func (*WriteGroupKafkaOptions) String added in v0.0.49 

func (m *WriteGroupKafkaOptions) String() string

func (*WriteGroupKafkaOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupKafkaOptions) XXX_DiscardUnknown()

func (*WriteGroupKafkaOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupKafkaOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupKafkaOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupKafkaOptions) XXX_Merge(src proto.Message)

func (*WriteGroupKafkaOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupKafkaOptions) XXX_Size() int

func (*WriteGroupKafkaOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupKafkaOptions) XXX_Unmarshal(b []byte) error

type WriteGroupKubeMQQueueOptions added in v0.0.49 

type WriteGroupKubeMQQueueOptions struct {
	// @gotags: kong:"embed"
	XConn *args.KubeMQQueueConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.KubeMQQueueWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*WriteGroupKubeMQQueueOptions) Descriptor added in v0.0.49 

func (*WriteGroupKubeMQQueueOptions) Descriptor() ([]byte, []int)

func (*WriteGroupKubeMQQueueOptions) GetArgs added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) GetArgs() *args.KubeMQQueueWriteArgs

func (*WriteGroupKubeMQQueueOptions) GetXConn added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) GetXConn() *args.KubeMQQueueConn

func (*WriteGroupKubeMQQueueOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupKubeMQQueueOptions) ProtoMessage()

func (*WriteGroupKubeMQQueueOptions) Reset added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) Reset()

func (*WriteGroupKubeMQQueueOptions) String added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) String() string

func (*WriteGroupKubeMQQueueOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) XXX_DiscardUnknown()

func (*WriteGroupKubeMQQueueOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupKubeMQQueueOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) XXX_Merge(src proto.Message)

func (*WriteGroupKubeMQQueueOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) XXX_Size() int

func (*WriteGroupKubeMQQueueOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) XXX_Unmarshal(b []byte) error

type WriteGroupMQTTOptions added in v0.0.49 

type WriteGroupMQTTOptions struct {
	// @gotags: kong:"embed"
	XConn *args.MQTTConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.MQTTWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*WriteGroupMQTTOptions) Descriptor added in v0.0.49 

func (*WriteGroupMQTTOptions) Descriptor() ([]byte, []int)

func (*WriteGroupMQTTOptions) GetArgs added in v0.0.49 

func (m *WriteGroupMQTTOptions) GetArgs() *args.MQTTWriteArgs

func (*WriteGroupMQTTOptions) GetXConn added in v0.0.49 

func (m *WriteGroupMQTTOptions) GetXConn() *args.MQTTConn

func (*WriteGroupMQTTOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupMQTTOptions) ProtoMessage()

func (*WriteGroupMQTTOptions) Reset added in v0.0.49 

func (m *WriteGroupMQTTOptions) Reset()

func (*WriteGroupMQTTOptions) String added in v0.0.49 

func (m *WriteGroupMQTTOptions) String() string

func (*WriteGroupMQTTOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupMQTTOptions) XXX_DiscardUnknown()

func (*WriteGroupMQTTOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupMQTTOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupMQTTOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupMQTTOptions) XXX_Merge(src proto.Message)

func (*WriteGroupMQTTOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupMQTTOptions) XXX_Size() int

func (*WriteGroupMQTTOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupMQTTOptions) XXX_Unmarshal(b []byte) error

type WriteGroupNSQOptions added in v0.0.49 

type WriteGroupNSQOptions struct {
	// @gotags: kong:"embed"
	XConn *args.NSQConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.NSQWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WriteGroupNSQOptions) Descriptor added in v0.0.49 

func (*WriteGroupNSQOptions) Descriptor() ([]byte, []int)

func (*WriteGroupNSQOptions) GetArgs added in v0.0.49 

func (m *WriteGroupNSQOptions) GetArgs() *args.NSQWriteArgs

func (*WriteGroupNSQOptions) GetXConn added in v0.0.49 

func (m *WriteGroupNSQOptions) GetXConn() *args.NSQConn

func (*WriteGroupNSQOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupNSQOptions) ProtoMessage()

func (*WriteGroupNSQOptions) Reset added in v0.0.49 

func (m *WriteGroupNSQOptions) Reset()

func (*WriteGroupNSQOptions) String added in v0.0.49 

func (m *WriteGroupNSQOptions) String() string

func (*WriteGroupNSQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupNSQOptions) XXX_DiscardUnknown()

func (*WriteGroupNSQOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupNSQOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupNSQOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupNSQOptions) XXX_Merge(src proto.Message)

func (*WriteGroupNSQOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupNSQOptions) XXX_Size() int

func (*WriteGroupNSQOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupNSQOptions) XXX_Unmarshal(b []byte) error

type WriteGroupNatsOptions added in v0.0.49 

type WriteGroupNatsOptions struct {
	// @gotags: kong:"embed"
	XConn *args.NatsConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.NatsWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*WriteGroupNatsOptions) Descriptor added in v0.0.49 

func (*WriteGroupNatsOptions) Descriptor() ([]byte, []int)

func (*WriteGroupNatsOptions) GetArgs added in v0.0.49 

func (m *WriteGroupNatsOptions) GetArgs() *args.NatsWriteArgs

func (*WriteGroupNatsOptions) GetXConn added in v0.0.49 

func (m *WriteGroupNatsOptions) GetXConn() *args.NatsConn

func (*WriteGroupNatsOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupNatsOptions) ProtoMessage()

func (*WriteGroupNatsOptions) Reset added in v0.0.49 

func (m *WriteGroupNatsOptions) Reset()

func (*WriteGroupNatsOptions) String added in v0.0.49 

func (m *WriteGroupNatsOptions) String() string

func (*WriteGroupNatsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupNatsOptions) XXX_DiscardUnknown()

func (*WriteGroupNatsOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupNatsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupNatsOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupNatsOptions) XXX_Merge(src proto.Message)

func (*WriteGroupNatsOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupNatsOptions) XXX_Size() int

func (*WriteGroupNatsOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupNatsOptions) XXX_Unmarshal(b []byte) error

type WriteGroupNatsStreamingOptions added in v0.0.49 

type WriteGroupNatsStreamingOptions struct {
	// @gotags: kong:"embed"
	XConn *args.NatsStreamingConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.NatsStreamingWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*WriteGroupNatsStreamingOptions) Descriptor added in v0.0.49 

func (*WriteGroupNatsStreamingOptions) Descriptor() ([]byte, []int)

func (*WriteGroupNatsStreamingOptions) GetArgs added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) GetArgs() *args.NatsStreamingWriteArgs

func (*WriteGroupNatsStreamingOptions) GetXConn added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) GetXConn() *args.NatsStreamingConn

func (*WriteGroupNatsStreamingOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupNatsStreamingOptions) ProtoMessage()

func (*WriteGroupNatsStreamingOptions) Reset added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) Reset()

func (*WriteGroupNatsStreamingOptions) String added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) String() string

func (*WriteGroupNatsStreamingOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) XXX_DiscardUnknown()

func (*WriteGroupNatsStreamingOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupNatsStreamingOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) XXX_Merge(src proto.Message)

func (*WriteGroupNatsStreamingOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) XXX_Size() int

func (*WriteGroupNatsStreamingOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) XXX_Unmarshal(b []byte) error

type WriteGroupPulsarOptions added in v0.0.49 

type WriteGroupPulsarOptions struct {
	// @gotags: kong:"embed"
	XConn *args.PulsarConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.PulsarWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*WriteGroupPulsarOptions) Descriptor added in v0.0.49 

func (*WriteGroupPulsarOptions) Descriptor() ([]byte, []int)

func (*WriteGroupPulsarOptions) GetArgs added in v0.0.49 

func (m *WriteGroupPulsarOptions) GetArgs() *args.PulsarWriteArgs

func (*WriteGroupPulsarOptions) GetXConn added in v0.0.49 

func (m *WriteGroupPulsarOptions) GetXConn() *args.PulsarConn

func (*WriteGroupPulsarOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupPulsarOptions) ProtoMessage()

func (*WriteGroupPulsarOptions) Reset added in v0.0.49 

func (m *WriteGroupPulsarOptions) Reset()

func (*WriteGroupPulsarOptions) String added in v0.0.49 

func (m *WriteGroupPulsarOptions) String() string

func (*WriteGroupPulsarOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupPulsarOptions) XXX_DiscardUnknown()

func (*WriteGroupPulsarOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupPulsarOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupPulsarOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupPulsarOptions) XXX_Merge(src proto.Message)

func (*WriteGroupPulsarOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupPulsarOptions) XXX_Size() int

func (*WriteGroupPulsarOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupPulsarOptions) XXX_Unmarshal(b []byte) error

type WriteGroupRabbitOptions added in v0.0.49 

type WriteGroupRabbitOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RabbitConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RabbitWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*WriteGroupRabbitOptions) Descriptor added in v0.0.49 

func (*WriteGroupRabbitOptions) Descriptor() ([]byte, []int)

func (*WriteGroupRabbitOptions) GetArgs added in v0.0.49 

func (m *WriteGroupRabbitOptions) GetArgs() *args.RabbitWriteArgs

func (*WriteGroupRabbitOptions) GetXConn added in v0.0.49 

func (m *WriteGroupRabbitOptions) GetXConn() *args.RabbitConn

func (*WriteGroupRabbitOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRabbitOptions) ProtoMessage()

func (*WriteGroupRabbitOptions) Reset added in v0.0.49 

func (m *WriteGroupRabbitOptions) Reset()

func (*WriteGroupRabbitOptions) String added in v0.0.49 

func (m *WriteGroupRabbitOptions) String() string

func (*WriteGroupRabbitOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupRabbitOptions) XXX_DiscardUnknown()

func (*WriteGroupRabbitOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupRabbitOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupRabbitOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupRabbitOptions) XXX_Merge(src proto.Message)

func (*WriteGroupRabbitOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupRabbitOptions) XXX_Size() int

func (*WriteGroupRabbitOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupRabbitOptions) XXX_Unmarshal(b []byte) error

type WriteGroupRabbitStreamsOptions added in v0.0.49 

type WriteGroupRabbitStreamsOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RabbitStreamsConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RabbitStreamsWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*WriteGroupRabbitStreamsOptions) Descriptor added in v0.0.49 

func (*WriteGroupRabbitStreamsOptions) Descriptor() ([]byte, []int)

func (*WriteGroupRabbitStreamsOptions) GetArgs added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) GetArgs() *args.RabbitStreamsWriteArgs

func (*WriteGroupRabbitStreamsOptions) GetXConn added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) GetXConn() *args.RabbitStreamsConn

func (*WriteGroupRabbitStreamsOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRabbitStreamsOptions) ProtoMessage()

func (*WriteGroupRabbitStreamsOptions) Reset added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) Reset()

func (*WriteGroupRabbitStreamsOptions) String added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) String() string

func (*WriteGroupRabbitStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) XXX_DiscardUnknown()

func (*WriteGroupRabbitStreamsOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupRabbitStreamsOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) XXX_Merge(src proto.Message)

func (*WriteGroupRabbitStreamsOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) XXX_Size() int

func (*WriteGroupRabbitStreamsOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) XXX_Unmarshal(b []byte) error

type WriteGroupRedisPubSubOptions added in v0.0.49 

type WriteGroupRedisPubSubOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RedisPubSubConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RedisPubSubWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*WriteGroupRedisPubSubOptions) Descriptor added in v0.0.49 

func (*WriteGroupRedisPubSubOptions) Descriptor() ([]byte, []int)

func (*WriteGroupRedisPubSubOptions) GetArgs added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) GetArgs() *args.RedisPubSubWriteArgs

func (*WriteGroupRedisPubSubOptions) GetXConn added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) GetXConn() *args.RedisPubSubConn

func (*WriteGroupRedisPubSubOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRedisPubSubOptions) ProtoMessage()

func (*WriteGroupRedisPubSubOptions) Reset added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) Reset()

func (*WriteGroupRedisPubSubOptions) String added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) String() string

func (*WriteGroupRedisPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) XXX_DiscardUnknown()

func (*WriteGroupRedisPubSubOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupRedisPubSubOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) XXX_Merge(src proto.Message)

func (*WriteGroupRedisPubSubOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) XXX_Size() int

func (*WriteGroupRedisPubSubOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) XXX_Unmarshal(b []byte) error

type WriteGroupRedisStreamsOptions added in v0.0.49 

type WriteGroupRedisStreamsOptions struct {
	// @gotags: kong:"embed"
	XConn *args.RedisStreamsConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args                 *args.RedisStreamsWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*WriteGroupRedisStreamsOptions) Descriptor added in v0.0.49 

func (*WriteGroupRedisStreamsOptions) Descriptor() ([]byte, []int)

func (*WriteGroupRedisStreamsOptions) GetArgs added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) GetArgs() *args.RedisStreamsWriteArgs

func (*WriteGroupRedisStreamsOptions) GetXConn added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) GetXConn() *args.RedisStreamsConn

func (*WriteGroupRedisStreamsOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRedisStreamsOptions) ProtoMessage()

func (*WriteGroupRedisStreamsOptions) Reset added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) Reset()

func (*WriteGroupRedisStreamsOptions) String added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) String() string

func (*WriteGroupRedisStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) XXX_DiscardUnknown()

func (*WriteGroupRedisStreamsOptions) XXX_Marshal added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteGroupRedisStreamsOptions) XXX_Merge added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) XXX_Merge(src proto.Message)

func (*WriteGroupRedisStreamsOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) XXX_Size() int

func (*WriteGroupRedisStreamsOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) XXX_Unmarshal(b []byte) error

type WriteOptions added in v0.0.49 

type WriteOptions struct {
	// Required for desktop; ignored in CLI.
	// @gotags: kong:"-"
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" kong:"-"`
	// @gotags: kong:"embed"
	Record *records.WriteRecord `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	EncodeOptions *encoding.EncodeOptions `protobuf:"bytes,3,opt,name=encode_options,json=encodeOptions,proto3" json:"encode_options,omitempty" kong:"embed"`
	// Optional; CLI-specific and non-backend-specific options
	// @gotags: kong:"embed"
	XCliOptions *WriteCLIOptions `protobuf:"bytes,1000,opt,name=_cli_options,json=CliOptions,proto3" json:"_cli_options,omitempty" kong:"embed"`
	// @gotags: kong:"cmd,help='Apache Kafka'"
	Kafka *WriteGroupKafkaOptions `protobuf:"bytes,100,opt,name=kafka,proto3" json:"kafka,omitempty" kong:"cmd,help='Apache Kafka'"`
	// @gotags: kong:"cmd,help='Apache ActiveMQ'"
	Activemq *WriteGroupActiveMQOptions `protobuf:"bytes,101,opt,name=activemq,proto3" json:"activemq,omitempty" kong:"cmd,help='Apache ActiveMQ'"`
	// @gotags: kong:"cmd,help='AWS Simple Queue System'"
	Awssqs *WriteGroupAWSSQSOptions `protobuf:"bytes,102,opt,name=awssqs,proto3" json:"awssqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='AWS Simple Notification System'"
	Awssns *WriteGroupAWSSNSOptions `protobuf:"bytes,103,opt,name=awssns,proto3" json:"awssns,omitempty" kong:"cmd,help='AWS Simple Notification System'"`
	// @gotags: kong:"cmd,help='NATS'"
	Nats *WriteGroupNatsOptions `protobuf:"bytes,104,opt,name=nats,proto3" json:"nats,omitempty" kong:"cmd,help='NATS'"`
	// @gotags: kong:"cmd,help='NATS Streaming'"
	NatsStreaming *WriteGroupNatsStreamingOptions `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *WriteGroupNSQOptions `protobuf:"bytes,106,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='Apache Pulsar'"
	Pulsar *WriteGroupPulsarOptions `protobuf:"bytes,107,opt,name=pulsar,proto3" json:"pulsar,omitempty" kong:"cmd,help='Apache Pulsar'"`
	// @gotags: kong:"cmd,help='RabbitMQ'"
	Rabbit *WriteGroupRabbitOptions `protobuf:"bytes,108,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='RabbitMQ'"`
	// @gotags: kong:"cmd,help='RabbitMQ Streams'"
	RabbitStreams *WriteGroupRabbitStreamsOptions `` /* 137-byte string literal not displayed */
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *WriteGroupMQTTOptions `protobuf:"bytes,110,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *WriteGroupAzureServiceBusOptions `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Azure Event Hub'"
	AzureEventHub *WriteGroupAzureEventHubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Google Cloud Platform Pub/Sub'"
	GcpPubsub *WriteGroupGCPPubSubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *WriteGroupKubeMQQueueOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *WriteGroupRedisPubSubOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams         *WriteGroupRedisStreamsOptions `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

Write is the structure that backends accept for facilitating a write. NOTE: _conn is only used by the CLI - desktop does not need to set it.

func (*WriteOptions) Descriptor added in v0.0.49 

func (*WriteOptions) Descriptor() ([]byte, []int)

func (*WriteOptions) GetActivemq added in v0.0.49 

func (m *WriteOptions) GetActivemq() *WriteGroupActiveMQOptions

func (*WriteOptions) GetAwssns added in v0.0.49 

func (m *WriteOptions) GetAwssns() *WriteGroupAWSSNSOptions

func (*WriteOptions) GetAwssqs added in v0.0.49 

func (m *WriteOptions) GetAwssqs() *WriteGroupAWSSQSOptions

func (*WriteOptions) GetAzureEventHub added in v0.0.49 

func (m *WriteOptions) GetAzureEventHub() *WriteGroupAzureEventHubOptions

func (*WriteOptions) GetAzureServiceBus added in v0.0.49 

func (m *WriteOptions) GetAzureServiceBus() *WriteGroupAzureServiceBusOptions

func (*WriteOptions) GetConnectionId added in v0.0.49 

func (m *WriteOptions) GetConnectionId() string

func (*WriteOptions) GetEncodeOptions added in v0.0.50 

func (m *WriteOptions) GetEncodeOptions() *encoding.EncodeOptions

func (*WriteOptions) GetGcpPubsub added in v0.0.49 

func (m *WriteOptions) GetGcpPubsub() *WriteGroupGCPPubSubOptions

func (*WriteOptions) GetKafka added in v0.0.49 

func (m *WriteOptions) GetKafka() *WriteGroupKafkaOptions

func (*WriteOptions) GetKubemqQueue added in v0.0.49 

func (m *WriteOptions) GetKubemqQueue() *WriteGroupKubeMQQueueOptions

func (*WriteOptions) GetMqtt added in v0.0.49 

func (m *WriteOptions) GetMqtt() *WriteGroupMQTTOptions

func (*WriteOptions) GetNats added in v0.0.49 

func (m *WriteOptions) GetNats() *WriteGroupNatsOptions

func (*WriteOptions) GetNatsStreaming added in v0.0.49 

func (m *WriteOptions) GetNatsStreaming() *WriteGroupNatsStreamingOptions

func (*WriteOptions) GetNsq added in v0.0.49 

func (m *WriteOptions) GetNsq() *WriteGroupNSQOptions

func (*WriteOptions) GetPulsar added in v0.0.49 

func (m *WriteOptions) GetPulsar() *WriteGroupPulsarOptions

func (*WriteOptions) GetRabbit added in v0.0.49 

func (m *WriteOptions) GetRabbit() *WriteGroupRabbitOptions

func (*WriteOptions) GetRabbitStreams added in v0.0.49 

func (m *WriteOptions) GetRabbitStreams() *WriteGroupRabbitStreamsOptions

func (*WriteOptions) GetRecord added in v0.0.49 

func (m *WriteOptions) GetRecord() *records.WriteRecord

func (*WriteOptions) GetRedisPubsub added in v0.0.49 

func (m *WriteOptions) GetRedisPubsub() *WriteGroupRedisPubSubOptions

func (*WriteOptions) GetRedisStreams added in v0.0.49 

func (m *WriteOptions) GetRedisStreams() *WriteGroupRedisStreamsOptions

func (*WriteOptions) GetXCliOptions added in v0.0.49 

func (m *WriteOptions) GetXCliOptions() *WriteCLIOptions

func (*WriteOptions) ProtoMessage added in v0.0.49 

func (*WriteOptions) ProtoMessage()

func (*WriteOptions) Reset added in v0.0.49 

func (m *WriteOptions) Reset()

func (*WriteOptions) String added in v0.0.49 

func (m *WriteOptions) String() string

func (*WriteOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteOptions) XXX_DiscardUnknown()

func (*WriteOptions) XXX_Marshal added in v0.0.49 

func (m *WriteOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteOptions) XXX_Merge added in v0.0.49 

func (m *WriteOptions) XXX_Merge(src proto.Message)

func (*WriteOptions) XXX_Size added in v0.0.49 

func (m *WriteOptions) XXX_Size() int

func (*WriteOptions) XXX_Unmarshal added in v0.0.49 

func (m *WriteOptions) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.