opts

package
v0.0.185 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 8 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",
	}
	ConvertOption_value = map[string]int32{
		"CONVERT_OPTION_UNSET":  0,
		"CONVERT_OPTION_BASE64": 1,
		"CONVERT_OPTION_GZIP":   2,
	}
)

Enum value maps for ConvertOption.

View Source 
var (
	InferSchemaOptions_Type_name = map[int32]string{
		0: "UNSET",
		1: "JSONSCHEMA",
	}
	InferSchemaOptions_Type_value = map[string]int32{
		"UNSET":      0,
		"JSONSCHEMA": 1,
	}
)

Enum value maps for InferSchemaOptions_Type.

View Source 
var (
	StreamdalOutputType_name = map[int32]string{
		0: "TABLE",
		1: "JSON",
	}
	StreamdalOutputType_value = map[string]int32{
		"TABLE": 0,
		"JSON":  1,
	}
)

Enum value maps for StreamdalOutputType.

View Source 
var (
	StreamdalReplayType_name = map[int32]string{
		0: "SINGLE",
		1: "CONTINUOUS",
	}
	StreamdalReplayType_value = map[string]int32{
		"SINGLE":     0,
		"CONTINUOUS": 1,
	}
)

Enum value maps for StreamdalReplayType.

View Source 
var File_opts_ps_opts_cli_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_connection_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_manage_connection_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_manage_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_manage_relay_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_manage_tunnel_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_read_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_relay_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_server_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_streamdal_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_tunnel_proto protoreflect.FileDescriptor
View Source 
var File_opts_ps_opts_write_proto protoreflect.FileDescriptor

Functions

func MergeRelayOptions added in v0.0.149 

func MergeRelayOptions(backend string, relayOpts *RelayOptions, createRelayOpts *CreateRelayOptions) error

func MergeTunnelOptions added in v0.0.153 

func MergeTunnelOptions(backend string, tunnelOpts *TunnelOptions, createTunnelOpts *CreateTunnelOptions) error

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 Streamdal'"
	Relay *RelayOptions `` /* 133-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Use plumber as a destination tunnel in Streamdal'"
	Tunnel *TunnelOptions `` /* 132-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Control your Streamdal resources via the public API'"
	Streamdal *StreamdalOptions `` /* 141-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Run plumber in server mode'"
	Server *ServerOptions `protobuf:"bytes,7,opt,name=server,proto3" json:"server,omitempty" kong:"cmd,help='Run plumber in server mode'"`
	// @gotags: kong:"cmd,help='Manage plumber server'"
	Manage *ManageOptions `protobuf:"bytes,8,opt,name=manage,proto3" json:"manage,omitempty" kong:"cmd,help='Manage plumber server'"`
	// contains filtered or unexported fields
}

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 deprecated added in v0.0.51 

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

Deprecated: Use CLIOptions.ProtoReflect.Descriptor instead.

func (*CLIOptions) GetGlobal added in v0.0.51 

func (x *CLIOptions) GetGlobal() *GlobalCLIOptions

func (*CLIOptions) GetManage added in v0.0.143 

func (x *CLIOptions) GetManage() *ManageOptions

func (*CLIOptions) GetRead added in v0.0.51 

func (x *CLIOptions) GetRead() *ReadOptions

func (*CLIOptions) GetRelay added in v0.0.51 

func (x *CLIOptions) GetRelay() *RelayOptions

func (*CLIOptions) GetServer added in v0.0.51 

func (x *CLIOptions) GetServer() *ServerOptions

func (*CLIOptions) GetStreamdal added in v0.0.175 

func (x *CLIOptions) GetStreamdal() *StreamdalOptions

func (*CLIOptions) GetTunnel added in v0.0.142 

func (x *CLIOptions) GetTunnel() *TunnelOptions

func (*CLIOptions) GetWrite added in v0.0.51 

func (x *CLIOptions) GetWrite() *WriteOptions

func (*CLIOptions) ProtoMessage added in v0.0.51 

func (*CLIOptions) ProtoMessage()

func (*CLIOptions) ProtoReflect added in v0.0.181 

func (x *CLIOptions) ProtoReflect() protoreflect.Message

func (*CLIOptions) Reset added in v0.0.51 

func (x *CLIOptions) Reset()

func (*CLIOptions) String added in v0.0.51 

func (x *CLIOptions) String() string

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 assignable 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
	//	*ConnectionOptions_NatsJetstream
	//	*ConnectionOptions_AwsKinesis
	//	*ConnectionOptions_Memphis
	Conn isConnectionOptions_Conn `protobuf_oneof:"conn"`
	// Used internally by plumber
	XId string `protobuf:"bytes,1000,opt,name=_id,json=Id,proto3" json:"_id,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated added in v0.0.49 

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

Deprecated: Use ConnectionOptions.ProtoReflect.Descriptor instead.

func (*ConnectionOptions) GetActiveMq added in v0.0.49 

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

func (*ConnectionOptions) GetAwsKinesis added in v0.0.121 

func (x *ConnectionOptions) GetAwsKinesis() *args.AWSKinesisConn

func (*ConnectionOptions) GetAwsSns added in v0.0.114 

func (x *ConnectionOptions) GetAwsSns() *args.AWSSNSConn

func (*ConnectionOptions) GetAwsSqs added in v0.0.114 

func (x *ConnectionOptions) GetAwsSqs() *args.AWSSQSConn

func (*ConnectionOptions) GetAzureEventHub added in v0.0.49 

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

func (*ConnectionOptions) GetAzureServiceBus added in v0.0.49 

func (x *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 (x *ConnectionOptions) GetGcpPubsub() *args.GCPPubSubConn

func (*ConnectionOptions) GetKafka added in v0.0.49 

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

func (*ConnectionOptions) GetKubemqQueue added in v0.0.49 

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

func (*ConnectionOptions) GetMemphis added in v0.0.177 

func (x *ConnectionOptions) GetMemphis() *args.MemphisConn

func (*ConnectionOptions) GetMongo added in v0.0.49 

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

func (*ConnectionOptions) GetMqtt added in v0.0.49 

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

func (*ConnectionOptions) GetName added in v0.0.49 

func (x *ConnectionOptions) GetName() string

func (*ConnectionOptions) GetNats added in v0.0.49 

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

func (*ConnectionOptions) GetNatsJetstream added in v0.0.119 

func (x *ConnectionOptions) GetNatsJetstream() *args.NatsJetstreamConn

func (*ConnectionOptions) GetNatsStreaming added in v0.0.49 

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

func (*ConnectionOptions) GetNotes added in v0.0.49 

func (x *ConnectionOptions) GetNotes() string

func (*ConnectionOptions) GetNsq added in v0.0.49 

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

func (*ConnectionOptions) GetPostgres added in v0.0.49 

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

func (*ConnectionOptions) GetPulsar added in v0.0.49 

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

func (*ConnectionOptions) GetRabbit added in v0.0.49 

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

func (*ConnectionOptions) GetRabbitStreams added in v0.0.49 

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

func (*ConnectionOptions) GetRedisPubsub added in v0.0.49 

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

func (*ConnectionOptions) GetRedisStreams added in v0.0.49 

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

func (*ConnectionOptions) GetXId added in v0.0.49 

func (x *ConnectionOptions) GetXId() string

func (*ConnectionOptions) ProtoMessage added in v0.0.49 

func (*ConnectionOptions) ProtoMessage()

func (*ConnectionOptions) ProtoReflect added in v0.0.181 

func (x *ConnectionOptions) ProtoReflect() protoreflect.Message

func (*ConnectionOptions) Reset added in v0.0.49 

func (x *ConnectionOptions) Reset()

func (*ConnectionOptions) String added in v0.0.49 

func (x *ConnectionOptions) String() string

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_AwsKinesis added in v0.0.121 

type ConnectionOptions_AwsKinesis struct {
	AwsKinesis *args.AWSKinesisConn `protobuf:"bytes,120,opt,name=aws_kinesis,json=awsKinesis,proto3,oneof"`
}

type ConnectionOptions_AwsSns added in v0.0.114 

type ConnectionOptions_AwsSns struct {
	AwsSns *args.AWSSNSConn `protobuf:"bytes,103,opt,name=aws_sns,json=awsSns,proto3,oneof"`
}

type ConnectionOptions_AwsSqs added in v0.0.114 

type ConnectionOptions_AwsSqs struct {
	AwsSqs *args.AWSSQSConn `protobuf:"bytes,102,opt,name=aws_sqs,json=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_Memphis added in v0.0.177 

type ConnectionOptions_Memphis struct {
	Memphis *args.MemphisConn `protobuf:"bytes,121,opt,name=memphis,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_NatsJetstream added in v0.0.119 

type ConnectionOptions_NatsJetstream struct {
	NatsJetstream *args.NatsJetstreamConn `protobuf:"bytes,119,opt,name=nats_jetstream,json=natsJetstream,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) Descriptor added in v0.0.181 

func (ConvertOption) Descriptor() protoreflect.EnumDescriptor

func (ConvertOption) Enum added in v0.0.181 

func (x ConvertOption) Enum() *ConvertOption

func (ConvertOption) EnumDescriptor deprecated added in v0.0.49 

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

Deprecated: Use ConvertOption.Descriptor instead.

func (ConvertOption) Number added in v0.0.181 

func (x ConvertOption) Number() protoreflect.EnumNumber

func (ConvertOption) String added in v0.0.49 

func (x ConvertOption) String() string

func (ConvertOption) Type added in v0.0.181 

func (ConvertOption) Type() protoreflect.EnumType

type CreateConnectionOptions added in v0.0.143 

type CreateConnectionOptions struct {

	// @gotags: kong:"help='Friendly name for the connection', required"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" kong:"help='Friendly name for the connection', required"`
	// @gotags: kong:"help='Optional notes to associate with the connection'"
	Notes string `protobuf:"bytes,2,opt,name=notes,proto3" json:"notes,omitempty" kong:"help='Optional notes to associate with the connection'"`
	// @gotags: kong:"cmd,help='Apache Kafka'"
	Kafka *args.KafkaConn `protobuf:"bytes,100,opt,name=kafka,proto3" json:"kafka,omitempty" kong:"cmd,help='Apache Kafka'"`
	// @gotags: kong:"cmd,help='ActiveMQ'"
	ActiveMq *args.ActiveMQConn `protobuf:"bytes,101,opt,name=active_mq,json=activeMq,proto3" json:"active_mq,omitempty" kong:"cmd,help='ActiveMQ'"`
	// @gotags: kong:"cmd,help='AWS Simple Queue Service'"
	AwsSqs *args.AWSSQSConn `protobuf:"bytes,102,opt,name=aws_sqs,json=awsSqs,proto3" json:"aws_sqs,omitempty" kong:"cmd,help='AWS Simple Queue Service'"`
	// @gotags: kong:"cmd,help='AWS Simple Notification Service'"
	AwsSns *args.AWSSNSConn `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Mongo (CDC)'"
	Mongo *args.MongoConn `protobuf:"bytes,104,opt,name=mongo,proto3" json:"mongo,omitempty" kong:"cmd,help='Mongo (CDC)'"`
	// @gotags: kong:"cmd,help='NATS PubSub'"
	Nats *args.NatsConn `protobuf:"bytes,105,opt,name=nats,proto3" json:"nats,omitempty" kong:"cmd,help='NATS PubSub'"`
	// @gotags: kong:"cmd,help='NATS Streaming (deprecated)'"
	NatsStreaming *args.NatsStreamingConn `` /* 148-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *args.NSQConn `protobuf:"bytes,107,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='PostgreSQL (CDC)'"
	Postgres *args.PostgresConn `protobuf:"bytes,108,opt,name=postgres,proto3" json:"postgres,omitempty" kong:"cmd,help='PostgreSQL (CDC)'"`
	// @gotags: kong:"cmd,help='Pulsar'"
	Pulsar *args.PulsarConn `protobuf:"bytes,109,opt,name=pulsar,proto3" json:"pulsar,omitempty" kong:"cmd,help='Pulsar'"`
	// @gotags: kong:"cmd,help='Rabbit'"
	Rabbit *args.RabbitConn `protobuf:"bytes,110,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='Rabbit'"`
	// @gotags: kong:"cmd,help='Rabbit Streams'"
	RabbitStreams *args.RabbitStreamsConn `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *args.RedisPubSubConn `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams *args.RedisStreamsConn `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Azure Event Hub'"
	AzureEventHub *args.AzureEventHubConn `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *args.AzureServiceBusConn `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *args.MQTTConn `protobuf:"bytes,116,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *args.KubeMQQueueConn `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Google Cloud Pub/Sub'"
	GcpPubsub *args.GCPPubSubConn `` /* 129-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NATS JetStream'"
	NatsJetstream *args.NatsJetstreamConn `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='AWS Kinesis'"
	AwsKinesis *args.AWSKinesisConn `protobuf:"bytes,120,opt,name=aws_kinesis,json=awsKinesis,proto3" json:"aws_kinesis,omitempty" kong:"cmd,help='AWS Kinesis'"`
	// contains filtered or unexported fields
}

func (*CreateConnectionOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use CreateConnectionOptions.ProtoReflect.Descriptor instead.

func (*CreateConnectionOptions) GetActiveMq added in v0.0.143 

func (x *CreateConnectionOptions) GetActiveMq() *args.ActiveMQConn

func (*CreateConnectionOptions) GetAwsKinesis added in v0.0.143 

func (x *CreateConnectionOptions) GetAwsKinesis() *args.AWSKinesisConn

func (*CreateConnectionOptions) GetAwsSns added in v0.0.143 

func (x *CreateConnectionOptions) GetAwsSns() *args.AWSSNSConn

func (*CreateConnectionOptions) GetAwsSqs added in v0.0.143 

func (x *CreateConnectionOptions) GetAwsSqs() *args.AWSSQSConn

func (*CreateConnectionOptions) GetAzureEventHub added in v0.0.143 

func (x *CreateConnectionOptions) GetAzureEventHub() *args.AzureEventHubConn

func (*CreateConnectionOptions) GetAzureServiceBus added in v0.0.143 

func (x *CreateConnectionOptions) GetAzureServiceBus() *args.AzureServiceBusConn

func (*CreateConnectionOptions) GetGcpPubsub added in v0.0.143 

func (x *CreateConnectionOptions) GetGcpPubsub() *args.GCPPubSubConn

func (*CreateConnectionOptions) GetKafka added in v0.0.143 

func (x *CreateConnectionOptions) GetKafka() *args.KafkaConn

func (*CreateConnectionOptions) GetKubemqQueue added in v0.0.143 

func (x *CreateConnectionOptions) GetKubemqQueue() *args.KubeMQQueueConn

func (*CreateConnectionOptions) GetMongo added in v0.0.143 

func (x *CreateConnectionOptions) GetMongo() *args.MongoConn

func (*CreateConnectionOptions) GetMqtt added in v0.0.143 

func (x *CreateConnectionOptions) GetMqtt() *args.MQTTConn

func (*CreateConnectionOptions) GetName added in v0.0.143 

func (x *CreateConnectionOptions) GetName() string

func (*CreateConnectionOptions) GetNats added in v0.0.143 

func (x *CreateConnectionOptions) GetNats() *args.NatsConn

func (*CreateConnectionOptions) GetNatsJetstream added in v0.0.143 

func (x *CreateConnectionOptions) GetNatsJetstream() *args.NatsJetstreamConn

func (*CreateConnectionOptions) GetNatsStreaming added in v0.0.143 

func (x *CreateConnectionOptions) GetNatsStreaming() *args.NatsStreamingConn

func (*CreateConnectionOptions) GetNotes added in v0.0.143 

func (x *CreateConnectionOptions) GetNotes() string

func (*CreateConnectionOptions) GetNsq added in v0.0.143 

func (x *CreateConnectionOptions) GetNsq() *args.NSQConn

func (*CreateConnectionOptions) GetPostgres added in v0.0.143 

func (x *CreateConnectionOptions) GetPostgres() *args.PostgresConn

func (*CreateConnectionOptions) GetPulsar added in v0.0.143 

func (x *CreateConnectionOptions) GetPulsar() *args.PulsarConn

func (*CreateConnectionOptions) GetRabbit added in v0.0.143 

func (x *CreateConnectionOptions) GetRabbit() *args.RabbitConn

func (*CreateConnectionOptions) GetRabbitStreams added in v0.0.143 

func (x *CreateConnectionOptions) GetRabbitStreams() *args.RabbitStreamsConn

func (*CreateConnectionOptions) GetRedisPubsub added in v0.0.143 

func (x *CreateConnectionOptions) GetRedisPubsub() *args.RedisPubSubConn

func (*CreateConnectionOptions) GetRedisStreams added in v0.0.143 

func (x *CreateConnectionOptions) GetRedisStreams() *args.RedisStreamsConn

func (*CreateConnectionOptions) ProtoMessage added in v0.0.143 

func (*CreateConnectionOptions) ProtoMessage()

func (*CreateConnectionOptions) ProtoReflect added in v0.0.181 

func (x *CreateConnectionOptions) ProtoReflect() protoreflect.Message

func (*CreateConnectionOptions) Reset added in v0.0.143 

func (x *CreateConnectionOptions) Reset()

func (*CreateConnectionOptions) String added in v0.0.143 

func (x *CreateConnectionOptions) String() string

type CreateOptions added in v0.0.143 

type CreateOptions struct {

	// @gotags: kong:"cmd,help='Create connection in plumber server'"
	Connection *CreateConnectionOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Create relay in plumber server'"
	Relay *CreateRelayOptions `protobuf:"bytes,2,opt,name=relay,proto3" json:"relay,omitempty" kong:"cmd,help='Create relay in plumber server'"`
	// @gotags: kong:"cmd,help='Create tunnel in plumber server'"
	Tunnel *CreateTunnelOptions `protobuf:"bytes,3,opt,name=tunnel,proto3" json:"tunnel,omitempty" kong:"cmd,help='Create tunnel in plumber server'"`
	// contains filtered or unexported fields
}

func (*CreateOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use CreateOptions.ProtoReflect.Descriptor instead.

func (*CreateOptions) GetConnection added in v0.0.143 

func (x *CreateOptions) GetConnection() *CreateConnectionOptions

func (*CreateOptions) GetRelay added in v0.0.143 

func (x *CreateOptions) GetRelay() *CreateRelayOptions

func (*CreateOptions) GetTunnel added in v0.0.143 

func (x *CreateOptions) GetTunnel() *CreateTunnelOptions

func (*CreateOptions) ProtoMessage added in v0.0.143 

func (*CreateOptions) ProtoMessage()

func (*CreateOptions) ProtoReflect added in v0.0.181 

func (x *CreateOptions) ProtoReflect() protoreflect.Message

func (*CreateOptions) Reset added in v0.0.143 

func (x *CreateOptions) Reset()

func (*CreateOptions) String added in v0.0.143 

func (x *CreateOptions) String() string

type CreateRelayOptions added in v0.0.143 

type CreateRelayOptions struct {

	// @gotags: kong:"help='ID of the connection to use',required"
	ConnectionId string `` /* 148-byte string literal not displayed */
	// @gotags: kong:"help='Secret collection token',required"
	CollectionToken string `` /* 153-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 */
	// @gotags: kong:"help='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',default='grpc-collector.streamdal.com:9000'"
	StreamdalGrpcAddress string `` /* 222-byte string literal not displayed */
	// @gotags: kong:"help='Whether to use TLS with collector'"
	StreamdalGrpcDisableTls bool `` /* 183-byte string literal not displayed */
	// @gotags: kong:"help='How long to wait before giving up talking to the gRPC collector',default=5"
	StreamdalGrpcTimeoutSeconds int32 `` /* 235-byte string literal not displayed */
	// @gotags: kong:"help='Consumed messages are intended to be dead-lettered'"
	DeadLetter bool `` /* 157-byte string literal not displayed */
	// @gotags: kong:"embed"
	StreamdalIntegrationOptions *StreamdalIntegrationOptions `` /* 158-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Apache Kafka'"
	Kafka *args.KafkaRelayArgs `protobuf:"bytes,100,opt,name=kafka,proto3" json:"kafka,omitempty" kong:"cmd,help='Apache Kafka'"`
	// @gotags: kong:"cmd,help='AWS Simple Queue System'"
	AwsSqs *args.AWSSQSRelayArgs `protobuf:"bytes,101,opt,name=aws_sqs,json=awsSqs,proto3" json:"aws_sqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='MongoDB (CDC)'"
	Mongo *args.MongoReadArgs `protobuf:"bytes,102,opt,name=mongo,proto3" json:"mongo,omitempty" kong:"cmd,help='MongoDB (CDC)'"`
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *args.NSQReadArgs `protobuf:"bytes,103,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='MQTT'"
	Rabbit *args.RabbitReadArgs `protobuf:"bytes,104,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *args.MQTTReadArgs `protobuf:"bytes,105,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *args.AzureServiceBusReadArgs `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Google Cloud Platform Pub/Sub'"
	GcpPubsub *args.GCPPubSubReadArgs `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *args.KubeMQQueueReadArgs `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *args.RedisPubSubReadArgs `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams *args.RedisStreamsReadArgs `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='PostgreSQL (CDC)'"
	Postgres *args.PostgresReadArgs `protobuf:"bytes,112,opt,name=postgres,proto3" json:"postgres,omitempty" kong:"cmd,help='PostgreSQL (CDC)'"`
	// @gotags: kong:"cmd,help='NATS'"
	Nats *args.NatsReadArgs `protobuf:"bytes,113,opt,name=nats,proto3" json:"nats,omitempty" kong:"cmd,help='NATS'"`
	// @gotags: kong:"cmd,help='NATS Streaming'"
	NatsStreaming *args.NatsStreamingReadArgs `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NATS JetStream'"
	NatsJetstream *args.NatsJetstreamReadArgs `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateRelayOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use CreateRelayOptions.ProtoReflect.Descriptor instead.

func (*CreateRelayOptions) GetAwsSqs added in v0.0.143 

func (x *CreateRelayOptions) GetAwsSqs() *args.AWSSQSRelayArgs

func (*CreateRelayOptions) GetAzureServiceBus added in v0.0.143 

func (x *CreateRelayOptions) GetAzureServiceBus() *args.AzureServiceBusReadArgs

func (*CreateRelayOptions) GetBatchMaxRetry added in v0.0.143 

func (x *CreateRelayOptions) GetBatchMaxRetry() int32

func (*CreateRelayOptions) GetBatchSize added in v0.0.143 

func (x *CreateRelayOptions) GetBatchSize() int32

func (*CreateRelayOptions) GetCollectionToken added in v0.0.143 

func (x *CreateRelayOptions) GetCollectionToken() string

func (*CreateRelayOptions) GetConnectionId added in v0.0.143 

func (x *CreateRelayOptions) GetConnectionId() string

func (*CreateRelayOptions) GetDeadLetter added in v0.0.174 

func (x *CreateRelayOptions) GetDeadLetter() bool

func (*CreateRelayOptions) GetGcpPubsub added in v0.0.143 

func (x *CreateRelayOptions) GetGcpPubsub() *args.GCPPubSubReadArgs

func (*CreateRelayOptions) GetKafka added in v0.0.143 

func (x *CreateRelayOptions) GetKafka() *args.KafkaRelayArgs

func (*CreateRelayOptions) GetKubemqQueue added in v0.0.143 

func (x *CreateRelayOptions) GetKubemqQueue() *args.KubeMQQueueReadArgs

func (*CreateRelayOptions) GetMongo added in v0.0.143 

func (x *CreateRelayOptions) GetMongo() *args.MongoReadArgs

func (*CreateRelayOptions) GetMqtt added in v0.0.143 

func (x *CreateRelayOptions) GetMqtt() *args.MQTTReadArgs

func (*CreateRelayOptions) GetNats added in v0.0.143 

func (x *CreateRelayOptions) GetNats() *args.NatsReadArgs

func (*CreateRelayOptions) GetNatsJetstream added in v0.0.143 

func (x *CreateRelayOptions) GetNatsJetstream() *args.NatsJetstreamReadArgs

func (*CreateRelayOptions) GetNatsStreaming added in v0.0.143 

func (x *CreateRelayOptions) GetNatsStreaming() *args.NatsStreamingReadArgs

func (*CreateRelayOptions) GetNsq added in v0.0.143 

func (x *CreateRelayOptions) GetNsq() *args.NSQReadArgs

func (*CreateRelayOptions) GetNumWorkers added in v0.0.143 

func (x *CreateRelayOptions) GetNumWorkers() int32

func (*CreateRelayOptions) GetPostgres added in v0.0.143 

func (x *CreateRelayOptions) GetPostgres() *args.PostgresReadArgs

func (*CreateRelayOptions) GetRabbit added in v0.0.143 

func (x *CreateRelayOptions) GetRabbit() *args.RabbitReadArgs

func (*CreateRelayOptions) GetRedisPubsub added in v0.0.143 

func (x *CreateRelayOptions) GetRedisPubsub() *args.RedisPubSubReadArgs

func (*CreateRelayOptions) GetRedisStreams added in v0.0.143 

func (x *CreateRelayOptions) GetRedisStreams() *args.RedisStreamsReadArgs

func (*CreateRelayOptions) GetStreamdalGrpcAddress added in v0.0.175 

func (x *CreateRelayOptions) GetStreamdalGrpcAddress() string

func (*CreateRelayOptions) GetStreamdalGrpcDisableTls added in v0.0.175 

func (x *CreateRelayOptions) GetStreamdalGrpcDisableTls() bool

func (*CreateRelayOptions) GetStreamdalGrpcTimeoutSeconds added in v0.0.175 

func (x *CreateRelayOptions) GetStreamdalGrpcTimeoutSeconds() int32

func (*CreateRelayOptions) GetStreamdalIntegrationOptions added in v0.0.185 

func (x *CreateRelayOptions) GetStreamdalIntegrationOptions() *StreamdalIntegrationOptions

func (*CreateRelayOptions) ProtoMessage added in v0.0.143 

func (*CreateRelayOptions) ProtoMessage()

func (*CreateRelayOptions) ProtoReflect added in v0.0.181 

func (x *CreateRelayOptions) ProtoReflect() protoreflect.Message

func (*CreateRelayOptions) Reset added in v0.0.143 

func (x *CreateRelayOptions) Reset()

func (*CreateRelayOptions) String added in v0.0.143 

func (x *CreateRelayOptions) String() string

type CreateTunnelOptions added in v0.0.143 

type CreateTunnelOptions struct {

	// @gotags: kong:"help='Connection ID for the tunnel to use',required=true"
	ConnectionId string `` /* 161-byte string literal not displayed */
	// @gotags: kong:"help='Streamdal API token (create in settings -> security)',required=true"
	TunnelToken string `` /* 175-byte string literal not displayed */
	// @gotags: kong:"help='Name for the tunnel (auto-generated if left empty)'"
	Name string `` /* 126-byte string literal not displayed */
	// @gotags: kong:"help='Notes associated with the tunnel'"
	Notes string `protobuf:"bytes,5,opt,name=notes,proto3" json:"notes,omitempty" kong:"help='Notes associated with the tunnel'"`
	// @gotags: kong:"help='Tunnel API address',default='dproxy.streamdal.com:443'"
	XTunnelAddress string `` /* 170-byte string literal not displayed */
	// @gotags: kong:"help='Tunnel API initial connection timeout',default=5"
	XTunnelTimeoutSeconds uint32 `` /* 188-byte string literal not displayed */
	// @gotags: kong:"help='Use gRPC insecure mode when talking to Streamdal Tunnel API'"
	XTunnelInsecure bool `` /* 180-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Apache Kafka'"
	Kafka *args.KafkaWriteArgs `protobuf:"bytes,100,opt,name=kafka,proto3" json:"kafka,omitempty" kong:"cmd,help='Apache Kafka'"`
	// @gotags: kong:"cmd,help='Apache ActiveMQ'"
	Activemq *args.ActiveMQWriteArgs `protobuf:"bytes,101,opt,name=activemq,proto3" json:"activemq,omitempty" kong:"cmd,help='Apache ActiveMQ'"`
	// @gotags: kong:"cmd,help='AWS Simple Queue System'"
	AwsSqs *args.AWSSQSWriteArgs `protobuf:"bytes,102,opt,name=aws_sqs,json=awsSqs,proto3" json:"aws_sqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='AWS Simple Notification System'"
	AwsSns *args.AWSSNSWriteArgs `` /* 130-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NATS'"
	Nats *args.NatsWriteArgs `protobuf:"bytes,104,opt,name=nats,proto3" json:"nats,omitempty" kong:"cmd,help='NATS'"`
	// @gotags: kong:"cmd,help='NATS Streaming'"
	NatsStreaming *args.NatsStreamingWriteArgs `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *args.NSQWriteArgs `protobuf:"bytes,106,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='RabbitMQ'"
	Rabbit *args.RabbitWriteArgs `protobuf:"bytes,107,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='RabbitMQ'"`
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *args.MQTTWriteArgs `protobuf:"bytes,108,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *args.AzureServiceBusWriteArgs `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Azure Event Hub'"
	AzureEventHub *args.AzureEventHubWriteArgs `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Google Cloud Platform Pub/Sub'"
	GcpPubsub *args.GCPPubSubWriteArgs `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *args.KubeMQQueueWriteArgs `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *args.RedisPubSubWriteArgs `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams *args.RedisStreamsWriteArgs `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Apache Pulsar'"
	Pulsar *args.PulsarWriteArgs `protobuf:"bytes,115,opt,name=pulsar,proto3" json:"pulsar,omitempty" kong:"cmd,help='Apache Pulsar'"`
	// @gotags: kong:"cmd,help='RabbitMQ Streams'"
	RabbitStreams *args.RabbitStreamsWriteArgs `` /* 137-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NATS JetStream'"
	NatsJetstream *args.NatsJetstreamWriteArgs `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='AWS Kinesis Streams'"
	AwsKinesis *args.AWSKinesisWriteArgs `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Memphis'"
	Memphis *args.MemphisWriteArgs `protobuf:"bytes,119,opt,name=memphis,proto3" json:"memphis,omitempty" kong:"cmd,help='Memphis'"`
	// contains filtered or unexported fields
}

func (*CreateTunnelOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use CreateTunnelOptions.ProtoReflect.Descriptor instead.

func (*CreateTunnelOptions) GetActivemq added in v0.0.143 

func (x *CreateTunnelOptions) GetActivemq() *args.ActiveMQWriteArgs

func (*CreateTunnelOptions) GetAwsKinesis added in v0.0.143 

func (x *CreateTunnelOptions) GetAwsKinesis() *args.AWSKinesisWriteArgs

func (*CreateTunnelOptions) GetAwsSns added in v0.0.143 

func (x *CreateTunnelOptions) GetAwsSns() *args.AWSSNSWriteArgs

func (*CreateTunnelOptions) GetAwsSqs added in v0.0.143 

func (x *CreateTunnelOptions) GetAwsSqs() *args.AWSSQSWriteArgs

func (*CreateTunnelOptions) GetAzureEventHub added in v0.0.143 

func (x *CreateTunnelOptions) GetAzureEventHub() *args.AzureEventHubWriteArgs

func (*CreateTunnelOptions) GetAzureServiceBus added in v0.0.143 

func (x *CreateTunnelOptions) GetAzureServiceBus() *args.AzureServiceBusWriteArgs

func (*CreateTunnelOptions) GetConnectionId added in v0.0.143 

func (x *CreateTunnelOptions) GetConnectionId() string

func (*CreateTunnelOptions) GetGcpPubsub added in v0.0.143 

func (x *CreateTunnelOptions) GetGcpPubsub() *args.GCPPubSubWriteArgs

func (*CreateTunnelOptions) GetKafka added in v0.0.143 

func (x *CreateTunnelOptions) GetKafka() *args.KafkaWriteArgs

func (*CreateTunnelOptions) GetKubemqQueue added in v0.0.143 

func (x *CreateTunnelOptions) GetKubemqQueue() *args.KubeMQQueueWriteArgs

func (*CreateTunnelOptions) GetMemphis added in v0.0.177 

func (x *CreateTunnelOptions) GetMemphis() *args.MemphisWriteArgs

func (*CreateTunnelOptions) GetMqtt added in v0.0.143 

func (x *CreateTunnelOptions) GetMqtt() *args.MQTTWriteArgs

func (*CreateTunnelOptions) GetName added in v0.0.143 

func (x *CreateTunnelOptions) GetName() string

func (*CreateTunnelOptions) GetNats added in v0.0.143 

func (x *CreateTunnelOptions) GetNats() *args.NatsWriteArgs

func (*CreateTunnelOptions) GetNatsJetstream added in v0.0.143 

func (x *CreateTunnelOptions) GetNatsJetstream() *args.NatsJetstreamWriteArgs

func (*CreateTunnelOptions) GetNatsStreaming added in v0.0.143 

func (x *CreateTunnelOptions) GetNatsStreaming() *args.NatsStreamingWriteArgs

func (*CreateTunnelOptions) GetNotes added in v0.0.143 

func (x *CreateTunnelOptions) GetNotes() string

func (*CreateTunnelOptions) GetNsq added in v0.0.143 

func (x *CreateTunnelOptions) GetNsq() *args.NSQWriteArgs

func (*CreateTunnelOptions) GetPulsar added in v0.0.143 

func (x *CreateTunnelOptions) GetPulsar() *args.PulsarWriteArgs

func (*CreateTunnelOptions) GetRabbit added in v0.0.143 

func (x *CreateTunnelOptions) GetRabbit() *args.RabbitWriteArgs

func (*CreateTunnelOptions) GetRabbitStreams added in v0.0.143 

func (x *CreateTunnelOptions) GetRabbitStreams() *args.RabbitStreamsWriteArgs

func (*CreateTunnelOptions) GetRedisPubsub added in v0.0.143 

func (x *CreateTunnelOptions) GetRedisPubsub() *args.RedisPubSubWriteArgs

func (*CreateTunnelOptions) GetRedisStreams added in v0.0.143 

func (x *CreateTunnelOptions) GetRedisStreams() *args.RedisStreamsWriteArgs

func (*CreateTunnelOptions) GetTunnelToken added in v0.0.152 

func (x *CreateTunnelOptions) GetTunnelToken() string

func (*CreateTunnelOptions) GetXTunnelAddress added in v0.0.143 

func (x *CreateTunnelOptions) GetXTunnelAddress() string

func (*CreateTunnelOptions) GetXTunnelInsecure added in v0.0.143 

func (x *CreateTunnelOptions) GetXTunnelInsecure() bool

func (*CreateTunnelOptions) GetXTunnelTimeoutSeconds added in v0.0.143 

func (x *CreateTunnelOptions) GetXTunnelTimeoutSeconds() uint32

func (*CreateTunnelOptions) ProtoMessage added in v0.0.143 

func (*CreateTunnelOptions) ProtoMessage()

func (*CreateTunnelOptions) ProtoReflect added in v0.0.181 

func (x *CreateTunnelOptions) ProtoReflect() protoreflect.Message

func (*CreateTunnelOptions) Reset added in v0.0.143 

func (x *CreateTunnelOptions) Reset()

func (*CreateTunnelOptions) String added in v0.0.143 

func (x *CreateTunnelOptions) String() string

type DeleteConnectionOptions added in v0.0.143 

type DeleteConnectionOptions struct {

	// @gotags: kong:"help='ID of the connection to delete',required=true"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the connection to delete',required=true"`
	// contains filtered or unexported fields
}

func (*DeleteConnectionOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use DeleteConnectionOptions.ProtoReflect.Descriptor instead.

func (*DeleteConnectionOptions) GetId added in v0.0.143 

func (x *DeleteConnectionOptions) GetId() string

func (*DeleteConnectionOptions) ProtoMessage added in v0.0.143 

func (*DeleteConnectionOptions) ProtoMessage()

func (*DeleteConnectionOptions) ProtoReflect added in v0.0.181 

func (x *DeleteConnectionOptions) ProtoReflect() protoreflect.Message

func (*DeleteConnectionOptions) Reset added in v0.0.143 

func (x *DeleteConnectionOptions) Reset()

func (*DeleteConnectionOptions) String added in v0.0.143 

func (x *DeleteConnectionOptions) String() string

type DeleteOptions added in v0.0.143 

type DeleteOptions struct {

	// @gotags: kong:"cmd,help='Delete connection in plumber server'"
	Connection *DeleteConnectionOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Delete relay in plumber server'"
	Relay *DeleteRelayOptions `protobuf:"bytes,2,opt,name=relay,proto3" json:"relay,omitempty" kong:"cmd,help='Delete relay in plumber server'"`
	// @gotags: kong:"cmd,help='Delete tunnel in plumber server'"
	Tunnel *DeleteTunnelOptions `protobuf:"bytes,3,opt,name=tunnel,proto3" json:"tunnel,omitempty" kong:"cmd,help='Delete tunnel in plumber server'"`
	// contains filtered or unexported fields
}

func (*DeleteOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use DeleteOptions.ProtoReflect.Descriptor instead.

func (*DeleteOptions) GetConnection added in v0.0.143 

func (x *DeleteOptions) GetConnection() *DeleteConnectionOptions

func (*DeleteOptions) GetRelay added in v0.0.143 

func (x *DeleteOptions) GetRelay() *DeleteRelayOptions

func (*DeleteOptions) GetTunnel added in v0.0.143 

func (x *DeleteOptions) GetTunnel() *DeleteTunnelOptions

func (*DeleteOptions) ProtoMessage added in v0.0.143 

func (*DeleteOptions) ProtoMessage()

func (*DeleteOptions) ProtoReflect added in v0.0.181 

func (x *DeleteOptions) ProtoReflect() protoreflect.Message

func (*DeleteOptions) Reset added in v0.0.143 

func (x *DeleteOptions) Reset()

func (*DeleteOptions) String added in v0.0.143 

func (x *DeleteOptions) String() string

type DeleteRelayOptions added in v0.0.143 

type DeleteRelayOptions struct {

	// @gotags: kong:"help='ID of the relay to delete',required=true"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the relay to delete',required=true"`
	// contains filtered or unexported fields
}

func (*DeleteRelayOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use DeleteRelayOptions.ProtoReflect.Descriptor instead.

func (*DeleteRelayOptions) GetId added in v0.0.143 

func (x *DeleteRelayOptions) GetId() string

func (*DeleteRelayOptions) ProtoMessage added in v0.0.143 

func (*DeleteRelayOptions) ProtoMessage()

func (*DeleteRelayOptions) ProtoReflect added in v0.0.181 

func (x *DeleteRelayOptions) ProtoReflect() protoreflect.Message

func (*DeleteRelayOptions) Reset added in v0.0.143 

func (x *DeleteRelayOptions) Reset()

func (*DeleteRelayOptions) String added in v0.0.143 

func (x *DeleteRelayOptions) String() string

type DeleteTunnelOptions added in v0.0.143 

type DeleteTunnelOptions struct {

	// @gotags: kong:"help='ID of the tunnel to delete',required=true"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the tunnel to delete',required=true"`
	// contains filtered or unexported fields
}

func (*DeleteTunnelOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use DeleteTunnelOptions.ProtoReflect.Descriptor instead.

func (*DeleteTunnelOptions) GetId added in v0.0.143 

func (x *DeleteTunnelOptions) GetId() string

func (*DeleteTunnelOptions) ProtoMessage added in v0.0.143 

func (*DeleteTunnelOptions) ProtoMessage()

func (*DeleteTunnelOptions) ProtoReflect added in v0.0.181 

func (x *DeleteTunnelOptions) ProtoReflect() protoreflect.Message

func (*DeleteTunnelOptions) Reset added in v0.0.143 

func (x *DeleteTunnelOptions) Reset()

func (*DeleteTunnelOptions) String added in v0.0.143 

func (x *DeleteTunnelOptions) String() string

type GetConnectionOptions added in v0.0.143 

type GetConnectionOptions struct {

	// @gotags: kong:"help='ID of the connection to get (leave empty to get all)'"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the connection to get (leave empty to get all)'"`
	// contains filtered or unexported fields
}

func (*GetConnectionOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use GetConnectionOptions.ProtoReflect.Descriptor instead.

func (*GetConnectionOptions) GetId added in v0.0.143 

func (x *GetConnectionOptions) GetId() string

func (*GetConnectionOptions) ProtoMessage added in v0.0.143 

func (*GetConnectionOptions) ProtoMessage()

func (*GetConnectionOptions) ProtoReflect added in v0.0.181 

func (x *GetConnectionOptions) ProtoReflect() protoreflect.Message

func (*GetConnectionOptions) Reset added in v0.0.143 

func (x *GetConnectionOptions) Reset()

func (*GetConnectionOptions) String added in v0.0.143 

func (x *GetConnectionOptions) String() string

type GetOptions added in v0.0.143 

type GetOptions struct {

	// @gotags: kong:"cmd,help='Get connection(s) from plumber server'"
	Connection *GetConnectionOptions `` /* 129-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Get relay(s) from plumber server'"
	Relay *GetRelayOptions `protobuf:"bytes,2,opt,name=relay,proto3" json:"relay,omitempty" kong:"cmd,help='Get relay(s) from plumber server'"`
	// @gotags: kong:"cmd,help='Get tunnel(s) from plumber server'"
	Tunnel *GetTunnelOptions `protobuf:"bytes,3,opt,name=tunnel,proto3" json:"tunnel,omitempty" kong:"cmd,help='Get tunnel(s) from plumber server'"`
	// contains filtered or unexported fields
}

func (*GetOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use GetOptions.ProtoReflect.Descriptor instead.

func (*GetOptions) GetConnection added in v0.0.143 

func (x *GetOptions) GetConnection() *GetConnectionOptions

func (*GetOptions) GetRelay added in v0.0.143 

func (x *GetOptions) GetRelay() *GetRelayOptions

func (*GetOptions) GetTunnel added in v0.0.143 

func (x *GetOptions) GetTunnel() *GetTunnelOptions

func (*GetOptions) ProtoMessage added in v0.0.143 

func (*GetOptions) ProtoMessage()

func (*GetOptions) ProtoReflect added in v0.0.181 

func (x *GetOptions) ProtoReflect() protoreflect.Message

func (*GetOptions) Reset added in v0.0.143 

func (x *GetOptions) Reset()

func (*GetOptions) String added in v0.0.143 

func (x *GetOptions) String() string

type GetRelayOptions added in v0.0.143 

type GetRelayOptions struct {

	// @gotags: kong:"help='ID of the relay to get (leave empty to get all)'"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the relay to get (leave empty to get all)'"`
	// contains filtered or unexported fields
}

func (*GetRelayOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use GetRelayOptions.ProtoReflect.Descriptor instead.

func (*GetRelayOptions) GetId added in v0.0.143 

func (x *GetRelayOptions) GetId() string

func (*GetRelayOptions) ProtoMessage added in v0.0.143 

func (*GetRelayOptions) ProtoMessage()

func (*GetRelayOptions) ProtoReflect added in v0.0.181 

func (x *GetRelayOptions) ProtoReflect() protoreflect.Message

func (*GetRelayOptions) Reset added in v0.0.143 

func (x *GetRelayOptions) Reset()

func (*GetRelayOptions) String added in v0.0.143 

func (x *GetRelayOptions) String() string

type GetTunnelOptions added in v0.0.143 

type GetTunnelOptions struct {

	// @gotags: kong:"help='ID of the tunnel to get (leave empty to get all)'"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the tunnel to get (leave empty to get all)'"`
	// contains filtered or unexported fields
}

func (*GetTunnelOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use GetTunnelOptions.ProtoReflect.Descriptor instead.

func (*GetTunnelOptions) GetId added in v0.0.143 

func (x *GetTunnelOptions) GetId() string

func (*GetTunnelOptions) ProtoMessage added in v0.0.143 

func (*GetTunnelOptions) ProtoMessage()

func (*GetTunnelOptions) ProtoReflect added in v0.0.181 

func (x *GetTunnelOptions) ProtoReflect() protoreflect.Message

func (*GetTunnelOptions) Reset added in v0.0.143 

func (x *GetTunnelOptions) Reset()

func (*GetTunnelOptions) String added in v0.0.143 

func (x *GetTunnelOptions) 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:"-"`
	// @gotags: kong:"-"
	XCommands []string `protobuf:"bytes,1003,rep,name=_commands,json=Commands,proto3" json:"_commands,omitempty" kong:"-"`
	// contains filtered or unexported fields
}

func (*GlobalCLIOptions) Descriptor deprecated added in v0.0.51 

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

Deprecated: Use GlobalCLIOptions.ProtoReflect.Descriptor instead.

func (*GlobalCLIOptions) GetDebug added in v0.0.51 

func (x *GlobalCLIOptions) GetDebug() bool

func (*GlobalCLIOptions) GetQuiet added in v0.0.51 

func (x *GlobalCLIOptions) GetQuiet() bool

func (*GlobalCLIOptions) GetVersion added in v0.0.51 

func (x *GlobalCLIOptions) GetVersion() bool

func (*GlobalCLIOptions) GetXAction added in v0.0.51 

func (x *GlobalCLIOptions) GetXAction() string

func (*GlobalCLIOptions) GetXBackend added in v0.0.51 

func (x *GlobalCLIOptions) GetXBackend() string

func (*GlobalCLIOptions) GetXCommands added in v0.0.147 

func (x *GlobalCLIOptions) GetXCommands() []string

func (*GlobalCLIOptions) GetXFullCommand added in v0.0.51 

func (x *GlobalCLIOptions) GetXFullCommand() string

func (*GlobalCLIOptions) ProtoMessage added in v0.0.51 

func (*GlobalCLIOptions) ProtoMessage()

func (*GlobalCLIOptions) ProtoReflect added in v0.0.181 

func (x *GlobalCLIOptions) ProtoReflect() protoreflect.Message

func (*GlobalCLIOptions) Reset added in v0.0.51 

func (x *GlobalCLIOptions) Reset()

func (*GlobalCLIOptions) String added in v0.0.51 

func (x *GlobalCLIOptions) String() string

type GlobalManageOptions added in v0.0.143 

type GlobalManageOptions struct {

	// @gotags: kong:"help='Plumber server gRPC API address',default='localhost:9090'"
	ManageAddress string `` /* 171-byte string literal not displayed */
	// @gotags: kong:"help='Plumber server auth token',default='streamdal'"
	ManageToken string `` /* 154-byte string literal not displayed */
	// @gotags: kong:"help='gRPC call timeout seconds',default=10"
	ManageTimeoutSeconds int64 `` /* 175-byte string literal not displayed */
	// @gotags: kong:"help='Use TLS when talking to plumber server',default='false'"
	ManageUseTls bool `` /* 169-byte string literal not displayed */
	// @gotags: kong:"help='Skip TLS server certificate verification',default='false'"
	ManageInsecureTls bool `` /* 186-byte string literal not displayed */
	// @gotags: kong:"help='TLS CA file'"
	ManageTlsCaFile string `` /* 136-byte string literal not displayed */
	// @gotags: kong:"help='TLS client cert file'"
	ManageTlsCertFile string `` /* 151-byte string literal not displayed */
	// @gotags: kong:"help='TLS client key file'"
	ManageTlsKeyFile string `` /* 147-byte string literal not displayed */
	// @gotags: kong:"help='Disable pretty/colorized output',default='false'"
	DisablePretty bool `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GlobalManageOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use GlobalManageOptions.ProtoReflect.Descriptor instead.

func (*GlobalManageOptions) GetDisablePretty added in v0.0.148 

func (x *GlobalManageOptions) GetDisablePretty() bool

func (*GlobalManageOptions) GetManageAddress added in v0.0.147 

func (x *GlobalManageOptions) GetManageAddress() string

func (*GlobalManageOptions) GetManageInsecureTls added in v0.0.147 

func (x *GlobalManageOptions) GetManageInsecureTls() bool

func (*GlobalManageOptions) GetManageTimeoutSeconds added in v0.0.147 

func (x *GlobalManageOptions) GetManageTimeoutSeconds() int64

func (*GlobalManageOptions) GetManageTlsCaFile added in v0.0.147 

func (x *GlobalManageOptions) GetManageTlsCaFile() string

func (*GlobalManageOptions) GetManageTlsCertFile added in v0.0.147 

func (x *GlobalManageOptions) GetManageTlsCertFile() string

func (*GlobalManageOptions) GetManageTlsKeyFile added in v0.0.147 

func (x *GlobalManageOptions) GetManageTlsKeyFile() string

func (*GlobalManageOptions) GetManageToken added in v0.0.147 

func (x *GlobalManageOptions) GetManageToken() string

func (*GlobalManageOptions) GetManageUseTls added in v0.0.147 

func (x *GlobalManageOptions) GetManageUseTls() bool

func (*GlobalManageOptions) ProtoMessage added in v0.0.143 

func (*GlobalManageOptions) ProtoMessage()

func (*GlobalManageOptions) ProtoReflect added in v0.0.181 

func (x *GlobalManageOptions) ProtoReflect() protoreflect.Message

func (*GlobalManageOptions) Reset added in v0.0.143 

func (x *GlobalManageOptions) Reset()

func (*GlobalManageOptions) String added in v0.0.143 

func (x *GlobalManageOptions) String() string

type HTTPDestination added in v0.0.54 

type HTTPDestination struct {

	// @gotags: kong:"help='Full URL to HTTP server (ex: https://example.com/some/path)',required"
	Url string `` /* 142-byte string literal not displayed */
	// @gotags: kong:"help='Optional map of headers to pass on replay (--headers key1=value1,key2=value2..)'"
	Headers map[string]string `` /* 249-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HTTPDestination) Descriptor deprecated added in v0.0.54 

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

Deprecated: Use HTTPDestination.ProtoReflect.Descriptor instead.

func (*HTTPDestination) GetHeaders added in v0.0.54 

func (x *HTTPDestination) GetHeaders() map[string]string

func (*HTTPDestination) GetUrl added in v0.0.54 

func (x *HTTPDestination) GetUrl() string

func (*HTTPDestination) ProtoMessage added in v0.0.54 

func (*HTTPDestination) ProtoMessage()

func (*HTTPDestination) ProtoReflect added in v0.0.181 

func (x *HTTPDestination) ProtoReflect() protoreflect.Message

func (*HTTPDestination) Reset added in v0.0.54 

func (x *HTTPDestination) Reset()

func (*HTTPDestination) String added in v0.0.54 

func (x *HTTPDestination) String() string

type InferSchemaOptions added in v0.0.82 

type InferSchemaOptions struct {

	// Type of schema to infer from the data
	// @gotags: kong:"-"
	Type InferSchemaOptions_Type `protobuf:"varint,1,opt,name=type,proto3,enum=protos.opts.InferSchemaOptions_Type" json:"type,omitempty" kong:"-"`
	// Existing schema ID. Can be filled out by end user, or by plumber
	// If filled out by end user, plumber will pull the schema and evolve from it
	// If empty, plumber will make a new schema, save and publish to other instances, and then evolve from it
	// @gotags: kong:"-"
	SchemaId string `protobuf:"bytes,2,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty" kong:"-"`
	// contains filtered or unexported fields
}

func (*InferSchemaOptions) Descriptor deprecated added in v0.0.82 

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

Deprecated: Use InferSchemaOptions.ProtoReflect.Descriptor instead.

func (*InferSchemaOptions) GetSchemaId added in v0.0.82 

func (x *InferSchemaOptions) GetSchemaId() string

func (*InferSchemaOptions) GetType added in v0.0.82 

func (x *InferSchemaOptions) GetType() InferSchemaOptions_Type

func (*InferSchemaOptions) ProtoMessage added in v0.0.82 

func (*InferSchemaOptions) ProtoMessage()

func (*InferSchemaOptions) ProtoReflect added in v0.0.181 

func (x *InferSchemaOptions) ProtoReflect() protoreflect.Message

func (*InferSchemaOptions) Reset added in v0.0.82 

func (x *InferSchemaOptions) Reset()

func (*InferSchemaOptions) String added in v0.0.82 

func (x *InferSchemaOptions) String() string

type InferSchemaOptions_Type added in v0.0.82 

type InferSchemaOptions_Type int32
const (
	InferSchemaOptions_UNSET      InferSchemaOptions_Type = 0
	InferSchemaOptions_JSONSCHEMA InferSchemaOptions_Type = 1 // TODO: expand with other types when we support them
)

func (InferSchemaOptions_Type) Descriptor added in v0.0.181 

func (InferSchemaOptions_Type) Descriptor() protoreflect.EnumDescriptor

func (InferSchemaOptions_Type) Enum added in v0.0.181 

func (x InferSchemaOptions_Type) Enum() *InferSchemaOptions_Type

func (InferSchemaOptions_Type) EnumDescriptor deprecated added in v0.0.82 

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

Deprecated: Use InferSchemaOptions_Type.Descriptor instead.

func (InferSchemaOptions_Type) Number added in v0.0.181 

func (x InferSchemaOptions_Type) Number() protoreflect.EnumNumber

func (InferSchemaOptions_Type) String added in v0.0.82 

func (x InferSchemaOptions_Type) String() string

func (InferSchemaOptions_Type) Type added in v0.0.181 

func (InferSchemaOptions_Type) Type() protoreflect.EnumType

type IsConnectionOptions_Conn added in v0.0.49 

type IsConnectionOptions_Conn = isConnectionOptions_Conn

func GenerateConnOpts added in v0.0.61 

func GenerateConnOpts(backend string, connArgs interface{}) (IsConnectionOptions_Conn, bool)

type ManageOptions added in v0.0.143 

type ManageOptions struct {

	// @gotags: kong:"embed"
	GlobalOptions *GlobalManageOptions `protobuf:"bytes,1,opt,name=global_options,json=globalOptions,proto3" json:"global_options,omitempty" kong:"embed"`
	// @gotags: kong:"cmd,help='Get resource(s) from plumber server'"
	Get *GetOptions `protobuf:"bytes,2,opt,name=get,proto3" json:"get,omitempty" kong:"cmd,help='Get resource(s) from plumber server'"`
	// @gotags: kong:"cmd,help='Create resources in plumber server'"
	Create *CreateOptions `protobuf:"bytes,3,opt,name=create,proto3" json:"create,omitempty" kong:"cmd,help='Create resources in plumber server'"`
	// @gotags: kong:"cmd,help='Delete resources in plumber server'"
	Delete *DeleteOptions `protobuf:"bytes,5,opt,name=delete,proto3" json:"delete,omitempty" kong:"cmd,help='Delete resources in plumber server'"`
	// @gotags: kong:"cmd,help='Stop resources in plumber server'"
	Stop *StopOptions `protobuf:"bytes,6,opt,name=stop,proto3" json:"stop,omitempty" kong:"cmd,help='Stop resources in plumber server'"`
	// @gotags: kong:"cmd,help='Resume/Start resources in plumber server'"
	Resume *ResumeOptions `protobuf:"bytes,7,opt,name=resume,proto3" json:"resume,omitempty" kong:"cmd,help='Resume/Start resources in plumber server'"`
	// contains filtered or unexported fields
}

func (*ManageOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use ManageOptions.ProtoReflect.Descriptor instead.

func (*ManageOptions) GetCreate added in v0.0.143 

func (x *ManageOptions) GetCreate() *CreateOptions

func (*ManageOptions) GetDelete added in v0.0.143 

func (x *ManageOptions) GetDelete() *DeleteOptions

func (*ManageOptions) GetGet added in v0.0.143 

func (x *ManageOptions) GetGet() *GetOptions

func (*ManageOptions) GetGlobalOptions added in v0.0.143 

func (x *ManageOptions) GetGlobalOptions() *GlobalManageOptions

func (*ManageOptions) GetResume added in v0.0.143 

func (x *ManageOptions) GetResume() *ResumeOptions

func (*ManageOptions) GetStop added in v0.0.143 

func (x *ManageOptions) GetStop() *StopOptions

func (*ManageOptions) ProtoMessage added in v0.0.143 

func (*ManageOptions) ProtoMessage()

func (*ManageOptions) ProtoReflect added in v0.0.181 

func (x *ManageOptions) ProtoReflect() protoreflect.Message

func (*ManageOptions) Reset added in v0.0.143 

func (x *ManageOptions) Reset()

func (*ManageOptions) String added in v0.0.143 

func (x *ManageOptions) String() string

type ReadCLIOptions added in v0.0.49 

type ReadCLIOptions struct {

	// @gotags: kong:"help='Display more verbose information during reads (varies by backend)'"
	VerboseOutput bool `` /* 181-byte string literal not displayed */
	// @gotags: kong:"help='Pretty (colorized) output'"
	Pretty bool `protobuf:"varint,2,opt,name=pretty,proto3" json:"pretty,omitempty" kong:"help='Pretty (colorized) output'"`
	// @gotags: kong:"help='Display all output as JSON (including tabular metadata)'"
	Json bool `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReadCLIOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadCLIOptions.ProtoReflect.Descriptor instead.

func (*ReadCLIOptions) GetJson added in v0.0.117 

func (x *ReadCLIOptions) GetJson() bool

func (*ReadCLIOptions) GetPretty added in v0.0.54 

func (x *ReadCLIOptions) GetPretty() bool

func (*ReadCLIOptions) GetVerboseOutput added in v0.0.49 

func (x *ReadCLIOptions) GetVerboseOutput() bool

func (*ReadCLIOptions) ProtoMessage added in v0.0.49 

func (*ReadCLIOptions) ProtoMessage()

func (*ReadCLIOptions) ProtoReflect added in v0.0.181 

func (x *ReadCLIOptions) ProtoReflect() protoreflect.Message

func (*ReadCLIOptions) Reset added in v0.0.49 

func (x *ReadCLIOptions) Reset()

func (*ReadCLIOptions) String added in v0.0.49 

func (x *ReadCLIOptions) String() string

type ReadFilterOptions added in v0.0.75 

type ReadFilterOptions struct {

	// @gotags: kong:"-"
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty" kong:"-"`
	// contains filtered or unexported fields
}

func (*ReadFilterOptions) Descriptor deprecated added in v0.0.75 

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

Deprecated: Use ReadFilterOptions.ProtoReflect.Descriptor instead.

func (*ReadFilterOptions) GetQuery added in v0.0.75 

func (x *ReadFilterOptions) GetQuery() string

func (*ReadFilterOptions) ProtoMessage added in v0.0.75 

func (*ReadFilterOptions) ProtoMessage()

func (*ReadFilterOptions) ProtoReflect added in v0.0.181 

func (x *ReadFilterOptions) ProtoReflect() protoreflect.Message

func (*ReadFilterOptions) Reset added in v0.0.75 

func (x *ReadFilterOptions) Reset()

func (*ReadFilterOptions) String added in v0.0.75 

func (x *ReadFilterOptions) String() string

type ReadGroupAWSKinesisOptions added in v0.0.121 

type ReadGroupAWSKinesisOptions struct {

	// @gotags: kong:"embed"
	XConn *args.AWSKinesisConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.AWSKinesisReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*ReadGroupAWSKinesisOptions) Descriptor deprecated added in v0.0.121 

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

Deprecated: Use ReadGroupAWSKinesisOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupAWSKinesisOptions) GetArgs added in v0.0.121 

func (x *ReadGroupAWSKinesisOptions) GetArgs() *args.AWSKinesisReadArgs

func (*ReadGroupAWSKinesisOptions) GetXConn added in v0.0.121 

func (x *ReadGroupAWSKinesisOptions) GetXConn() *args.AWSKinesisConn

func (*ReadGroupAWSKinesisOptions) ProtoMessage added in v0.0.121 

func (*ReadGroupAWSKinesisOptions) ProtoMessage()

func (*ReadGroupAWSKinesisOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupAWSKinesisOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupAWSKinesisOptions) Reset added in v0.0.121 

func (x *ReadGroupAWSKinesisOptions) Reset()

func (*ReadGroupAWSKinesisOptions) String added in v0.0.121 

func (x *ReadGroupAWSKinesisOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupAWSSQSOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupAWSSQSOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupAWSSQSOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupAWSSQSOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupAWSSQSOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupAWSSQSOptions) ProtoMessage()

func (*ReadGroupAWSSQSOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupAWSSQSOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupAWSSQSOptions) Reset added in v0.0.49 

func (x *ReadGroupAWSSQSOptions) Reset()

func (*ReadGroupAWSSQSOptions) String added in v0.0.49 

func (x *ReadGroupAWSSQSOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupActiveMQOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupActiveMQOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupActiveMQOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupActiveMQOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupActiveMQOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupActiveMQOptions) ProtoMessage()

func (*ReadGroupActiveMQOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupActiveMQOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupActiveMQOptions) Reset added in v0.0.49 

func (x *ReadGroupActiveMQOptions) Reset()

func (*ReadGroupActiveMQOptions) String added in v0.0.49 

func (x *ReadGroupActiveMQOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupAzureEventHubOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupAzureEventHubOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupAzureEventHubOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupAzureEventHubOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupAzureEventHubOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupAzureEventHubOptions) ProtoMessage()

func (*ReadGroupAzureEventHubOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupAzureEventHubOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupAzureEventHubOptions) Reset added in v0.0.49 

func (x *ReadGroupAzureEventHubOptions) Reset()

func (*ReadGroupAzureEventHubOptions) String added in v0.0.49 

func (x *ReadGroupAzureEventHubOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupAzureServiceBusOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupAzureServiceBusOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupAzureServiceBusOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupAzureServiceBusOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupAzureServiceBusOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupAzureServiceBusOptions) ProtoMessage()

func (*ReadGroupAzureServiceBusOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupAzureServiceBusOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupAzureServiceBusOptions) Reset added in v0.0.49 

func (x *ReadGroupAzureServiceBusOptions) Reset()

func (*ReadGroupAzureServiceBusOptions) String added in v0.0.49 

func (x *ReadGroupAzureServiceBusOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupGCPPubSubOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupGCPPubSubOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupGCPPubSubOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupGCPPubSubOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupGCPPubSubOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupGCPPubSubOptions) ProtoMessage()

func (*ReadGroupGCPPubSubOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupGCPPubSubOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupGCPPubSubOptions) Reset added in v0.0.49 

func (x *ReadGroupGCPPubSubOptions) Reset()

func (*ReadGroupGCPPubSubOptions) String added in v0.0.49 

func (x *ReadGroupGCPPubSubOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupKafkaOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupKafkaOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupKafkaOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupKafkaOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupKafkaOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupKafkaOptions) ProtoMessage()

func (*ReadGroupKafkaOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupKafkaOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupKafkaOptions) Reset added in v0.0.49 

func (x *ReadGroupKafkaOptions) Reset()

func (*ReadGroupKafkaOptions) String added in v0.0.49 

func (x *ReadGroupKafkaOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupKubeMQQueueOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupKubeMQQueueOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupKubeMQQueueOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupKubeMQQueueOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupKubeMQQueueOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupKubeMQQueueOptions) ProtoMessage()

func (*ReadGroupKubeMQQueueOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupKubeMQQueueOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupKubeMQQueueOptions) Reset added in v0.0.49 

func (x *ReadGroupKubeMQQueueOptions) Reset()

func (*ReadGroupKubeMQQueueOptions) String added in v0.0.49 

func (x *ReadGroupKubeMQQueueOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupMQTTOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupMQTTOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupMQTTOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupMQTTOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupMQTTOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupMQTTOptions) ProtoMessage()

func (*ReadGroupMQTTOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupMQTTOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupMQTTOptions) Reset added in v0.0.49 

func (x *ReadGroupMQTTOptions) Reset()

func (*ReadGroupMQTTOptions) String added in v0.0.49 

func (x *ReadGroupMQTTOptions) String() string

type ReadGroupMemphisOptions added in v0.0.177 

type ReadGroupMemphisOptions struct {

	// @gotags: kong:"embed"
	XConn *args.MemphisConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.MemphisReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*ReadGroupMemphisOptions) Descriptor deprecated added in v0.0.177 

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

Deprecated: Use ReadGroupMemphisOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupMemphisOptions) GetArgs added in v0.0.177 

func (x *ReadGroupMemphisOptions) GetArgs() *args.MemphisReadArgs

func (*ReadGroupMemphisOptions) GetXConn added in v0.0.177 

func (x *ReadGroupMemphisOptions) GetXConn() *args.MemphisConn

func (*ReadGroupMemphisOptions) ProtoMessage added in v0.0.177 

func (*ReadGroupMemphisOptions) ProtoMessage()

func (*ReadGroupMemphisOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupMemphisOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupMemphisOptions) Reset added in v0.0.177 

func (x *ReadGroupMemphisOptions) Reset()

func (*ReadGroupMemphisOptions) String added in v0.0.177 

func (x *ReadGroupMemphisOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupMongoOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupMongoOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupMongoOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupMongoOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupMongoOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupMongoOptions) ProtoMessage()

func (*ReadGroupMongoOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupMongoOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupMongoOptions) Reset added in v0.0.49 

func (x *ReadGroupMongoOptions) Reset()

func (*ReadGroupMongoOptions) String added in v0.0.49 

func (x *ReadGroupMongoOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupNSQOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupNSQOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupNSQOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupNSQOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupNSQOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupNSQOptions) ProtoMessage()

func (*ReadGroupNSQOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupNSQOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupNSQOptions) Reset added in v0.0.49 

func (x *ReadGroupNSQOptions) Reset()

func (*ReadGroupNSQOptions) String added in v0.0.49 

func (x *ReadGroupNSQOptions) String() string

type ReadGroupNatsJetstreamOptions added in v0.0.119 

type ReadGroupNatsJetstreamOptions struct {

	// @gotags: kong:"embed"
	XConn *args.NatsJetstreamConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.NatsJetstreamReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*ReadGroupNatsJetstreamOptions) Descriptor deprecated added in v0.0.119 

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

Deprecated: Use ReadGroupNatsJetstreamOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupNatsJetstreamOptions) GetArgs added in v0.0.119 

func (x *ReadGroupNatsJetstreamOptions) GetArgs() *args.NatsJetstreamReadArgs

func (*ReadGroupNatsJetstreamOptions) GetXConn added in v0.0.119 

func (x *ReadGroupNatsJetstreamOptions) GetXConn() *args.NatsJetstreamConn

func (*ReadGroupNatsJetstreamOptions) ProtoMessage added in v0.0.119 

func (*ReadGroupNatsJetstreamOptions) ProtoMessage()

func (*ReadGroupNatsJetstreamOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupNatsJetstreamOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupNatsJetstreamOptions) Reset added in v0.0.119 

func (x *ReadGroupNatsJetstreamOptions) Reset()

func (*ReadGroupNatsJetstreamOptions) String added in v0.0.119 

func (x *ReadGroupNatsJetstreamOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupNatsOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupNatsOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupNatsOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupNatsOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupNatsOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupNatsOptions) ProtoMessage()

func (*ReadGroupNatsOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupNatsOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupNatsOptions) Reset added in v0.0.49 

func (x *ReadGroupNatsOptions) Reset()

func (*ReadGroupNatsOptions) String added in v0.0.49 

func (x *ReadGroupNatsOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupNatsStreamingOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupNatsStreamingOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupNatsStreamingOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupNatsStreamingOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupNatsStreamingOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupNatsStreamingOptions) ProtoMessage()

func (*ReadGroupNatsStreamingOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupNatsStreamingOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupNatsStreamingOptions) Reset added in v0.0.49 

func (x *ReadGroupNatsStreamingOptions) Reset()

func (*ReadGroupNatsStreamingOptions) String added in v0.0.49 

func (x *ReadGroupNatsStreamingOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupPostgresOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupPostgresOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupPostgresOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupPostgresOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupPostgresOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupPostgresOptions) ProtoMessage()

func (*ReadGroupPostgresOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupPostgresOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupPostgresOptions) Reset added in v0.0.49 

func (x *ReadGroupPostgresOptions) Reset()

func (*ReadGroupPostgresOptions) String added in v0.0.49 

func (x *ReadGroupPostgresOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupPulsarOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupPulsarOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupPulsarOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupPulsarOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupPulsarOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupPulsarOptions) ProtoMessage()

func (*ReadGroupPulsarOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupPulsarOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupPulsarOptions) Reset added in v0.0.49 

func (x *ReadGroupPulsarOptions) Reset()

func (*ReadGroupPulsarOptions) String added in v0.0.49 

func (x *ReadGroupPulsarOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupRabbitOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupRabbitOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupRabbitOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupRabbitOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupRabbitOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRabbitOptions) ProtoMessage()

func (*ReadGroupRabbitOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupRabbitOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupRabbitOptions) Reset added in v0.0.49 

func (x *ReadGroupRabbitOptions) Reset()

func (*ReadGroupRabbitOptions) String added in v0.0.49 

func (x *ReadGroupRabbitOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupRabbitStreamsOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupRabbitStreamsOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupRabbitStreamsOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupRabbitStreamsOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupRabbitStreamsOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRabbitStreamsOptions) ProtoMessage()

func (*ReadGroupRabbitStreamsOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupRabbitStreamsOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupRabbitStreamsOptions) Reset added in v0.0.49 

func (x *ReadGroupRabbitStreamsOptions) Reset()

func (*ReadGroupRabbitStreamsOptions) String added in v0.0.49 

func (x *ReadGroupRabbitStreamsOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupRedisPubSubOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupRedisPubSubOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupRedisPubSubOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupRedisPubSubOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupRedisPubSubOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRedisPubSubOptions) ProtoMessage()

func (*ReadGroupRedisPubSubOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupRedisPubSubOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupRedisPubSubOptions) Reset added in v0.0.49 

func (x *ReadGroupRedisPubSubOptions) Reset()

func (*ReadGroupRedisPubSubOptions) String added in v0.0.49 

func (x *ReadGroupRedisPubSubOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReadGroupRedisStreamsOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadGroupRedisStreamsOptions.ProtoReflect.Descriptor instead.

func (*ReadGroupRedisStreamsOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupRedisStreamsOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupRedisStreamsOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRedisStreamsOptions) ProtoMessage()

func (*ReadGroupRedisStreamsOptions) ProtoReflect added in v0.0.181 

func (x *ReadGroupRedisStreamsOptions) ProtoReflect() protoreflect.Message

func (*ReadGroupRedisStreamsOptions) Reset added in v0.0.49 

func (x *ReadGroupRedisStreamsOptions) Reset()

func (*ReadGroupRedisStreamsOptions) String added in v0.0.49 

func (x *ReadGroupRedisStreamsOptions) String() string

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: kong:"help='Follow/read continuously',short=f"
	Continuous bool `protobuf:"varint,3,opt,name=continuous,proto3" json:"continuous,omitempty" kong:"help='Follow/read continuously',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 */
	// @gotags: kong:"help='Convert output before it is printed to STDOUT (options: unset; base64; gzip)',type=pbenum,pbenum_strip_prefix=CONVERT_OPTION_,pbenum_lowercase,default=unset"
	ConvertOutput ConvertOption `` /* 302-byte string literal not displayed */
	// @gotags: kong:"-"
	Filter *ReadFilterOptions `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty" kong:"-"`
	// Whether to infer a JSON schema from this read. Ignored if schema_id is populated. Desktop use only
	// @gotags: kong:"-"
	InferSchemaOptions *InferSchemaOptions `` /* 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=aws_sqs,json=awsSqs,proto3" json:"aws_sqs,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='Azure Event Hub'"
	AzureEventHub *ReadGroupAzureEventHubOptions `` /* 138-byte string literal not displayed */
	// @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'"`
	// @gotags: kong:"cmd,help='NATS Jetstream'"
	NatsJetstream *ReadGroupNatsJetstreamOptions `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='AWS Kinesis Streams'"
	AwsKinesis *ReadGroupAWSKinesisOptions `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Memphis'"
	Memphis *ReadGroupMemphisOptions `protobuf:"bytes,120,opt,name=memphis,proto3" json:"memphis,omitempty" kong:"cmd,help='Memphis'"`
	// contains filtered or unexported fields
}

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

func (*ReadOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadOptions.ProtoReflect.Descriptor instead.

func (*ReadOptions) GetActivemq added in v0.0.49 

func (x *ReadOptions) GetActivemq() *ReadGroupActiveMQOptions

func (*ReadOptions) GetAwsKinesis added in v0.0.121 

func (x *ReadOptions) GetAwsKinesis() *ReadGroupAWSKinesisOptions

func (*ReadOptions) GetAwsSqs added in v0.0.114 

func (x *ReadOptions) GetAwsSqs() *ReadGroupAWSSQSOptions

func (*ReadOptions) GetAzureEventHub added in v0.0.49 

func (x *ReadOptions) GetAzureEventHub() *ReadGroupAzureEventHubOptions

func (*ReadOptions) GetAzureServiceBus added in v0.0.49 

func (x *ReadOptions) GetAzureServiceBus() *ReadGroupAzureServiceBusOptions

func (*ReadOptions) GetConnectionId added in v0.0.49 

func (x *ReadOptions) GetConnectionId() string

func (*ReadOptions) GetContinuous added in v0.0.49 

func (x *ReadOptions) GetContinuous() bool

func (*ReadOptions) GetConvertOutput added in v0.0.54 

func (x *ReadOptions) GetConvertOutput() ConvertOption

func (*ReadOptions) GetDecodeOptions added in v0.0.49 

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

func (*ReadOptions) GetFilter added in v0.0.75 

func (x *ReadOptions) GetFilter() *ReadFilterOptions

func (*ReadOptions) GetGcpPubsub added in v0.0.49 

func (x *ReadOptions) GetGcpPubsub() *ReadGroupGCPPubSubOptions

func (*ReadOptions) GetInferSchemaOptions added in v0.0.82 

func (x *ReadOptions) GetInferSchemaOptions() *InferSchemaOptions

func (*ReadOptions) GetKafka added in v0.0.49 

func (x *ReadOptions) GetKafka() *ReadGroupKafkaOptions

func (*ReadOptions) GetKubemqQueue added in v0.0.49 

func (x *ReadOptions) GetKubemqQueue() *ReadGroupKubeMQQueueOptions

func (*ReadOptions) GetMemphis added in v0.0.177 

func (x *ReadOptions) GetMemphis() *ReadGroupMemphisOptions

func (*ReadOptions) GetMongo added in v0.0.49 

func (x *ReadOptions) GetMongo() *ReadGroupMongoOptions

func (*ReadOptions) GetMqtt added in v0.0.49 

func (x *ReadOptions) GetMqtt() *ReadGroupMQTTOptions

func (*ReadOptions) GetName added in v0.0.49 

func (x *ReadOptions) GetName() string

func (*ReadOptions) GetNats added in v0.0.49 

func (x *ReadOptions) GetNats() *ReadGroupNatsOptions

func (*ReadOptions) GetNatsJetstream added in v0.0.119 

func (x *ReadOptions) GetNatsJetstream() *ReadGroupNatsJetstreamOptions

func (*ReadOptions) GetNatsStreaming added in v0.0.49 

func (x *ReadOptions) GetNatsStreaming() *ReadGroupNatsStreamingOptions

func (*ReadOptions) GetNsq added in v0.0.49 

func (x *ReadOptions) GetNsq() *ReadGroupNSQOptions

func (*ReadOptions) GetPostgres added in v0.0.49 

func (x *ReadOptions) GetPostgres() *ReadGroupPostgresOptions

func (*ReadOptions) GetPulsar added in v0.0.49 

func (x *ReadOptions) GetPulsar() *ReadGroupPulsarOptions

func (*ReadOptions) GetRabbit added in v0.0.49 

func (x *ReadOptions) GetRabbit() *ReadGroupRabbitOptions

func (*ReadOptions) GetRabbitStreams added in v0.0.49 

func (x *ReadOptions) GetRabbitStreams() *ReadGroupRabbitStreamsOptions

func (*ReadOptions) GetRedisPubsub added in v0.0.49 

func (x *ReadOptions) GetRedisPubsub() *ReadGroupRedisPubSubOptions

func (*ReadOptions) GetRedisStreams added in v0.0.49 

func (x *ReadOptions) GetRedisStreams() *ReadGroupRedisStreamsOptions

func (*ReadOptions) GetSampleOptions added in v0.0.49 

func (x *ReadOptions) GetSampleOptions() *ReadSampleOptions

func (*ReadOptions) GetXActive added in v0.0.49 

func (x *ReadOptions) GetXActive() bool

func (*ReadOptions) GetXCliOptions added in v0.0.49 

func (x *ReadOptions) GetXCliOptions() *ReadCLIOptions

func (*ReadOptions) GetXId added in v0.0.49 

func (x *ReadOptions) GetXId() string

func (*ReadOptions) ProtoMessage added in v0.0.49 

func (*ReadOptions) ProtoMessage()

func (*ReadOptions) ProtoReflect added in v0.0.181 

func (x *ReadOptions) ProtoReflect() protoreflect.Message

func (*ReadOptions) Reset added in v0.0.49 

func (x *ReadOptions) Reset()

func (*ReadOptions) String added in v0.0.49 

func (x *ReadOptions) String() string

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 */
	// contains filtered or unexported fields
}

func (*ReadSampleOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ReadSampleOptions.ProtoReflect.Descriptor instead.

func (*ReadSampleOptions) GetSampleIntervalSeconds added in v0.0.49 

func (x *ReadSampleOptions) GetSampleIntervalSeconds() uint32

func (*ReadSampleOptions) GetSampleRate added in v0.0.49 

func (x *ReadSampleOptions) GetSampleRate() uint32

func (*ReadSampleOptions) ProtoMessage added in v0.0.49 

func (*ReadSampleOptions) ProtoMessage()

func (*ReadSampleOptions) ProtoReflect added in v0.0.181 

func (x *ReadSampleOptions) ProtoReflect() protoreflect.Message

func (*ReadSampleOptions) Reset added in v0.0.49 

func (x *ReadSampleOptions) Reset()

func (*ReadSampleOptions) String added in v0.0.49 

func (x *ReadSampleOptions) String() string

type RelayCLIOptions added in v0.0.49 

type RelayCLIOptions struct {

	// @gotags: kong:"help='What address to bind the built-in HTTP server to',env='PLUMBER_RELAY_HTTP_LISTEN_ADDRESS',default='localhost:9191'"
	HttpListenAddress string `` /* 242-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RelayCLIOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayCLIOptions.ProtoReflect.Descriptor instead.

func (*RelayCLIOptions) GetHttpListenAddress added in v0.0.49 

func (x *RelayCLIOptions) GetHttpListenAddress() string

func (*RelayCLIOptions) ProtoMessage added in v0.0.49 

func (*RelayCLIOptions) ProtoMessage()

func (*RelayCLIOptions) ProtoReflect added in v0.0.181 

func (x *RelayCLIOptions) ProtoReflect() protoreflect.Message

func (*RelayCLIOptions) Reset added in v0.0.49 

func (x *RelayCLIOptions) Reset()

func (*RelayCLIOptions) String added in v0.0.49 

func (x *RelayCLIOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupAWSSQSOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupAWSSQSOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupAWSSQSOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupAWSSQSOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupAWSSQSOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupAWSSQSOptions) ProtoMessage()

func (*RelayGroupAWSSQSOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupAWSSQSOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupAWSSQSOptions) Reset added in v0.0.49 

func (x *RelayGroupAWSSQSOptions) Reset()

func (*RelayGroupAWSSQSOptions) String added in v0.0.49 

func (x *RelayGroupAWSSQSOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupAzureServiceBusOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupAzureServiceBusOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupAzureServiceBusOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupAzureServiceBusOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupAzureServiceBusOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupAzureServiceBusOptions) ProtoMessage()

func (*RelayGroupAzureServiceBusOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupAzureServiceBusOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupAzureServiceBusOptions) Reset added in v0.0.49 

func (x *RelayGroupAzureServiceBusOptions) Reset()

func (*RelayGroupAzureServiceBusOptions) String added in v0.0.49 

func (x *RelayGroupAzureServiceBusOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupGCPPubSubOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupGCPPubSubOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupGCPPubSubOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupGCPPubSubOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupGCPPubSubOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupGCPPubSubOptions) ProtoMessage()

func (*RelayGroupGCPPubSubOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupGCPPubSubOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupGCPPubSubOptions) Reset added in v0.0.49 

func (x *RelayGroupGCPPubSubOptions) Reset()

func (*RelayGroupGCPPubSubOptions) String added in v0.0.49 

func (x *RelayGroupGCPPubSubOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupKafkaOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupKafkaOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupKafkaOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupKafkaOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupKafkaOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupKafkaOptions) ProtoMessage()

func (*RelayGroupKafkaOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupKafkaOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupKafkaOptions) Reset added in v0.0.49 

func (x *RelayGroupKafkaOptions) Reset()

func (*RelayGroupKafkaOptions) String added in v0.0.49 

func (x *RelayGroupKafkaOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupKubeMQQueueOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupKubeMQQueueOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupKubeMQQueueOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupKubeMQQueueOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupKubeMQQueueOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupKubeMQQueueOptions) ProtoMessage()

func (*RelayGroupKubeMQQueueOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupKubeMQQueueOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupKubeMQQueueOptions) Reset added in v0.0.49 

func (x *RelayGroupKubeMQQueueOptions) Reset()

func (*RelayGroupKubeMQQueueOptions) String added in v0.0.49 

func (x *RelayGroupKubeMQQueueOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupMQTTOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupMQTTOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupMQTTOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupMQTTOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupMQTTOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupMQTTOptions) ProtoMessage()

func (*RelayGroupMQTTOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupMQTTOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupMQTTOptions) Reset added in v0.0.49 

func (x *RelayGroupMQTTOptions) Reset()

func (*RelayGroupMQTTOptions) String added in v0.0.49 

func (x *RelayGroupMQTTOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupMongoOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupMongoOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupMongoOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupMongoOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupMongoOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupMongoOptions) ProtoMessage()

func (*RelayGroupMongoOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupMongoOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupMongoOptions) Reset added in v0.0.49 

func (x *RelayGroupMongoOptions) Reset()

func (*RelayGroupMongoOptions) String added in v0.0.49 

func (x *RelayGroupMongoOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupNSQOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupNSQOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupNSQOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupNSQOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupNSQOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupNSQOptions) ProtoMessage()

func (*RelayGroupNSQOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupNSQOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupNSQOptions) Reset added in v0.0.49 

func (x *RelayGroupNSQOptions) Reset()

func (*RelayGroupNSQOptions) String added in v0.0.49 

func (x *RelayGroupNSQOptions) String() string

type RelayGroupNatsJetStreamOptions added in v0.0.125 

type RelayGroupNatsJetStreamOptions struct {

	// @gotags: kong:"embed"
	XConn *args.NatsJetstreamConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.NatsJetstreamReadArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*RelayGroupNatsJetStreamOptions) Descriptor deprecated added in v0.0.125 

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

Deprecated: Use RelayGroupNatsJetStreamOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupNatsJetStreamOptions) GetArgs added in v0.0.125 

func (x *RelayGroupNatsJetStreamOptions) GetArgs() *args.NatsJetstreamReadArgs

func (*RelayGroupNatsJetStreamOptions) GetXConn added in v0.0.125 

func (x *RelayGroupNatsJetStreamOptions) GetXConn() *args.NatsJetstreamConn

func (*RelayGroupNatsJetStreamOptions) ProtoMessage added in v0.0.125 

func (*RelayGroupNatsJetStreamOptions) ProtoMessage()

func (*RelayGroupNatsJetStreamOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupNatsJetStreamOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupNatsJetStreamOptions) Reset added in v0.0.125 

func (x *RelayGroupNatsJetStreamOptions) Reset()

func (*RelayGroupNatsJetStreamOptions) String added in v0.0.125 

func (x *RelayGroupNatsJetStreamOptions) String() string

type RelayGroupNatsOptions added in v0.0.125 

type RelayGroupNatsOptions 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"`
	// contains filtered or unexported fields
}

func (*RelayGroupNatsOptions) Descriptor deprecated added in v0.0.125 

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

Deprecated: Use RelayGroupNatsOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupNatsOptions) GetArgs added in v0.0.125 

func (x *RelayGroupNatsOptions) GetArgs() *args.NatsReadArgs

func (*RelayGroupNatsOptions) GetXConn added in v0.0.125 

func (x *RelayGroupNatsOptions) GetXConn() *args.NatsConn

func (*RelayGroupNatsOptions) ProtoMessage added in v0.0.125 

func (*RelayGroupNatsOptions) ProtoMessage()

func (*RelayGroupNatsOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupNatsOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupNatsOptions) Reset added in v0.0.125 

func (x *RelayGroupNatsOptions) Reset()

func (*RelayGroupNatsOptions) String added in v0.0.125 

func (x *RelayGroupNatsOptions) String() string

type RelayGroupNatsStreamingOptions added in v0.0.125 

type RelayGroupNatsStreamingOptions 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"`
	// contains filtered or unexported fields
}

func (*RelayGroupNatsStreamingOptions) Descriptor deprecated added in v0.0.125 

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

Deprecated: Use RelayGroupNatsStreamingOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupNatsStreamingOptions) GetArgs added in v0.0.125 

func (x *RelayGroupNatsStreamingOptions) GetArgs() *args.NatsStreamingReadArgs

func (*RelayGroupNatsStreamingOptions) GetXConn added in v0.0.125 

func (x *RelayGroupNatsStreamingOptions) GetXConn() *args.NatsStreamingConn

func (*RelayGroupNatsStreamingOptions) ProtoMessage added in v0.0.125 

func (*RelayGroupNatsStreamingOptions) ProtoMessage()

func (*RelayGroupNatsStreamingOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupNatsStreamingOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupNatsStreamingOptions) Reset added in v0.0.125 

func (x *RelayGroupNatsStreamingOptions) Reset()

func (*RelayGroupNatsStreamingOptions) String added in v0.0.125 

func (x *RelayGroupNatsStreamingOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupPostgresOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupPostgresOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupPostgresOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupPostgresOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupPostgresOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupPostgresOptions) ProtoMessage()

func (*RelayGroupPostgresOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupPostgresOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupPostgresOptions) Reset added in v0.0.49 

func (x *RelayGroupPostgresOptions) Reset()

func (*RelayGroupPostgresOptions) String added in v0.0.49 

func (x *RelayGroupPostgresOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupRabbitOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupRabbitOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupRabbitOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupRabbitOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupRabbitOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupRabbitOptions) ProtoMessage()

func (*RelayGroupRabbitOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupRabbitOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupRabbitOptions) Reset added in v0.0.49 

func (x *RelayGroupRabbitOptions) Reset()

func (*RelayGroupRabbitOptions) String added in v0.0.49 

func (x *RelayGroupRabbitOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupRedisPubSubOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupRedisPubSubOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupRedisPubSubOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupRedisPubSubOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupRedisPubSubOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupRedisPubSubOptions) ProtoMessage()

func (*RelayGroupRedisPubSubOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupRedisPubSubOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupRedisPubSubOptions) Reset added in v0.0.49 

func (x *RelayGroupRedisPubSubOptions) Reset()

func (*RelayGroupRedisPubSubOptions) String added in v0.0.49 

func (x *RelayGroupRedisPubSubOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*RelayGroupRedisStreamsOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use RelayGroupRedisStreamsOptions.ProtoReflect.Descriptor instead.

func (*RelayGroupRedisStreamsOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupRedisStreamsOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupRedisStreamsOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupRedisStreamsOptions) ProtoMessage()

func (*RelayGroupRedisStreamsOptions) ProtoReflect added in v0.0.181 

func (x *RelayGroupRedisStreamsOptions) ProtoReflect() protoreflect.Message

func (*RelayGroupRedisStreamsOptions) Reset added in v0.0.49 

func (x *RelayGroupRedisStreamsOptions) Reset()

func (*RelayGroupRedisStreamsOptions) String added in v0.0.49 

func (x *RelayGroupRedisStreamsOptions) String() string

type RelayOptions added in v0.0.49 

type RelayOptions struct {

	// @gotags: kong:"help='Secret collection token',env='PLUMBER_RELAY_TOKEN',name=token,required"
	CollectionToken string `` /* 190-byte string literal not displayed */
	// @gotags: kong:"help='How many messages to send in a single batch',env='PLUMBER_RELAY_BATCH_SIZE',default=1000"
	BatchSize int32 `` /* 191-byte string literal not displayed */
	// @gotags: kong:"help='How many times plumber will try re-sending a batch',env='PLUMBER_RELAY_BATCH_MAX_RETRY',default=3"
	BatchMaxRetry int32 `` /* 214-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:"help='How many workers to launch per relay',env='PLUMBER_RELAY_NUM_WORKERS',default=10"
	NumWorkers int32 `` /* 186-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 */
	// @gotags: kong:"help='Consumed messages are intended to be dead-lettered',env='PLUMBER_RELAY_DEAD_LETTER'"
	DeadLetter bool `` /* 189-byte string literal not displayed */
	// @gotags: kong:"embed"
	StreamdalIntegrationOptions *StreamdalIntegrationOptions `` /* 157-byte string literal not displayed */
	// @gotags: kong:"help='Alternative collector to relay events to',name='grpc-address',env='PLUMBER_RELAY_GRPC_ADDRESS',default='grpc-collector.streamdal.com:9000'"
	XStreamdalGrpcAddress string `` /* 280-byte string literal not displayed */
	// @gotags: kong:"help='Whether to use TLS with collector',name=grpc-disable-tls,env='PLUMBER_RELAY_GRPC_DISABLE_TLS',default=false"
	XStreamdalGrpcDisableTls bool `` /* 261-byte string literal not displayed */
	// @gotags: kong:"help='How long to wait before giving up talking to the gRPC collector',name='grpc-timeout-seconds',env='PLUMBER_RELAY_GRPC_TIMEOUT',default=5"
	XStreamdalGrpcTimeoutSeconds int32 `` /* 301-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"`
	// Populated by plumber server during GetRelay* methods
	// @gotags: kong:"-"
	XActive bool `protobuf:"varint,1005,opt,name=_active,json=Active,proto3" json:"_active,omitempty" kong:"-"`
	// @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=aws_sqs,json=awsSqs,proto3" json:"aws_sqs,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)'"`
	// @gotags: kong:"cmd,help='NATS'"
	Nats *RelayGroupNatsOptions `protobuf:"bytes,113,opt,name=nats,proto3" json:"nats,omitempty" kong:"cmd,help='NATS'"`
	// @gotags: kong:"cmd,help='NATS Streaming'"
	NatsStreaming *RelayGroupNatsStreamingOptions `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NATS JetStream'"
	NatsJetstream *RelayGroupNatsJetStreamOptions `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

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 deprecated added in v0.0.49 

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

Deprecated: Use RelayOptions.ProtoReflect.Descriptor instead.

func (*RelayOptions) GetAwsSqs added in v0.0.114 

func (x *RelayOptions) GetAwsSqs() *RelayGroupAWSSQSOptions

func (*RelayOptions) GetAzureServiceBus added in v0.0.49 

func (x *RelayOptions) GetAzureServiceBus() *RelayGroupAzureServiceBusOptions

func (*RelayOptions) GetBatchMaxRetry added in v0.0.49 

func (x *RelayOptions) GetBatchMaxRetry() int32

func (*RelayOptions) GetBatchSize added in v0.0.49 

func (x *RelayOptions) GetBatchSize() int32

func (*RelayOptions) GetCollectionToken added in v0.0.49 

func (x *RelayOptions) GetCollectionToken() string

func (*RelayOptions) GetConnectionId added in v0.0.49 

func (x *RelayOptions) GetConnectionId() string

func (*RelayOptions) GetDeadLetter added in v0.0.174 

func (x *RelayOptions) GetDeadLetter() bool

func (*RelayOptions) GetGcpPubsub added in v0.0.49 

func (x *RelayOptions) GetGcpPubsub() *RelayGroupGCPPubSubOptions

func (*RelayOptions) GetKafka added in v0.0.49 

func (x *RelayOptions) GetKafka() *RelayGroupKafkaOptions

func (*RelayOptions) GetKubemqQueue added in v0.0.49 

func (x *RelayOptions) GetKubemqQueue() *RelayGroupKubeMQQueueOptions

func (*RelayOptions) GetMongo added in v0.0.49 

func (x *RelayOptions) GetMongo() *RelayGroupMongoOptions

func (*RelayOptions) GetMqtt added in v0.0.49 

func (x *RelayOptions) GetMqtt() *RelayGroupMQTTOptions

func (*RelayOptions) GetNats added in v0.0.125 

func (x *RelayOptions) GetNats() *RelayGroupNatsOptions

func (*RelayOptions) GetNatsJetstream added in v0.0.125 

func (x *RelayOptions) GetNatsJetstream() *RelayGroupNatsJetStreamOptions

func (*RelayOptions) GetNatsStreaming added in v0.0.125 

func (x *RelayOptions) GetNatsStreaming() *RelayGroupNatsStreamingOptions

func (*RelayOptions) GetNsq added in v0.0.49 

func (x *RelayOptions) GetNsq() *RelayGroupNSQOptions

func (*RelayOptions) GetNumWorkers added in v0.0.49 

func (x *RelayOptions) GetNumWorkers() int32

func (*RelayOptions) GetPostgres added in v0.0.49 

func (x *RelayOptions) GetPostgres() *RelayGroupPostgresOptions

func (*RelayOptions) GetRabbit added in v0.0.49 

func (x *RelayOptions) GetRabbit() *RelayGroupRabbitOptions

func (*RelayOptions) GetRedisPubsub added in v0.0.49 

func (x *RelayOptions) GetRedisPubsub() *RelayGroupRedisPubSubOptions

func (*RelayOptions) GetRedisStreams added in v0.0.49 

func (x *RelayOptions) GetRedisStreams() *RelayGroupRedisStreamsOptions

func (*RelayOptions) GetStatsEnable added in v0.0.100 

func (x *RelayOptions) GetStatsEnable() bool

func (*RelayOptions) GetStatsReportIntervalSec added in v0.0.100 

func (x *RelayOptions) GetStatsReportIntervalSec() int32

func (*RelayOptions) GetStreamdalIntegrationOptions added in v0.0.185 

func (x *RelayOptions) GetStreamdalIntegrationOptions() *StreamdalIntegrationOptions

func (*RelayOptions) GetXActive added in v0.0.131 

func (x *RelayOptions) GetXActive() bool

func (*RelayOptions) GetXCliOptions added in v0.0.49 

func (x *RelayOptions) GetXCliOptions() *RelayCLIOptions

func (*RelayOptions) GetXRelayId added in v0.0.49 

func (x *RelayOptions) GetXRelayId() string

func (*RelayOptions) GetXStreamdalGrpcAddress added in v0.0.175 

func (x *RelayOptions) GetXStreamdalGrpcAddress() string

func (*RelayOptions) GetXStreamdalGrpcDisableTls added in v0.0.175 

func (x *RelayOptions) GetXStreamdalGrpcDisableTls() bool

func (*RelayOptions) GetXStreamdalGrpcTimeoutSeconds added in v0.0.175 

func (x *RelayOptions) GetXStreamdalGrpcTimeoutSeconds() int32

func (*RelayOptions) ProtoMessage added in v0.0.49 

func (*RelayOptions) ProtoMessage()

func (*RelayOptions) ProtoReflect added in v0.0.181 

func (x *RelayOptions) ProtoReflect() protoreflect.Message

func (*RelayOptions) Reset added in v0.0.49 

func (x *RelayOptions) Reset()

func (*RelayOptions) String added in v0.0.49 

func (x *RelayOptions) String() string

type ResumeOptions added in v0.0.143 

type ResumeOptions struct {

	// @gotags: kong:"cmd,help='Resume/Start relay in plumber server'"
	Relay *ResumeRelayOptions `protobuf:"bytes,1,opt,name=relay,proto3" json:"relay,omitempty" kong:"cmd,help='Resume/Start relay in plumber server'"`
	// @gotags: kong:"cmd,help='Resume/Start tunnel in plumber server'"
	Tunnel *ResumeTunnelOptions `protobuf:"bytes,2,opt,name=tunnel,proto3" json:"tunnel,omitempty" kong:"cmd,help='Resume/Start tunnel in plumber server'"`
	// contains filtered or unexported fields
}

func (*ResumeOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use ResumeOptions.ProtoReflect.Descriptor instead.

func (*ResumeOptions) GetRelay added in v0.0.143 

func (x *ResumeOptions) GetRelay() *ResumeRelayOptions

func (*ResumeOptions) GetTunnel added in v0.0.143 

func (x *ResumeOptions) GetTunnel() *ResumeTunnelOptions

func (*ResumeOptions) ProtoMessage added in v0.0.143 

func (*ResumeOptions) ProtoMessage()

func (*ResumeOptions) ProtoReflect added in v0.0.181 

func (x *ResumeOptions) ProtoReflect() protoreflect.Message

func (*ResumeOptions) Reset added in v0.0.143 

func (x *ResumeOptions) Reset()

func (*ResumeOptions) String added in v0.0.143 

func (x *ResumeOptions) String() string

type ResumeRelayOptions added in v0.0.143 

type ResumeRelayOptions struct {

	// @gotags: kong:"help='ID of the relay to resume',required=true"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the relay to resume',required=true"`
	// contains filtered or unexported fields
}

func (*ResumeRelayOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use ResumeRelayOptions.ProtoReflect.Descriptor instead.

func (*ResumeRelayOptions) GetId added in v0.0.143 

func (x *ResumeRelayOptions) GetId() string

func (*ResumeRelayOptions) ProtoMessage added in v0.0.143 

func (*ResumeRelayOptions) ProtoMessage()

func (*ResumeRelayOptions) ProtoReflect added in v0.0.181 

func (x *ResumeRelayOptions) ProtoReflect() protoreflect.Message

func (*ResumeRelayOptions) Reset added in v0.0.143 

func (x *ResumeRelayOptions) Reset()

func (*ResumeRelayOptions) String added in v0.0.143 

func (x *ResumeRelayOptions) String() string

type ResumeTunnelOptions added in v0.0.143 

type ResumeTunnelOptions struct {

	// @gotags: kong:"help='ID of the tunnel to resume',required=true"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the tunnel to resume',required=true"`
	// contains filtered or unexported fields
}

func (*ResumeTunnelOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use ResumeTunnelOptions.ProtoReflect.Descriptor instead.

func (*ResumeTunnelOptions) GetId added in v0.0.143 

func (x *ResumeTunnelOptions) GetId() string

func (*ResumeTunnelOptions) ProtoMessage added in v0.0.143 

func (*ResumeTunnelOptions) ProtoMessage()

func (*ResumeTunnelOptions) ProtoReflect added in v0.0.181 

func (x *ResumeTunnelOptions) ProtoReflect() protoreflect.Message

func (*ResumeTunnelOptions) Reset added in v0.0.143 

func (x *ResumeTunnelOptions) Reset()

func (*ResumeTunnelOptions) String added in v0.0.143 

func (x *ResumeTunnelOptions) String() string

type ServerOptions added in v0.0.49 

type ServerOptions struct {

	// @gotags: kong:"default=plumber1,help='Unique ID that identifies this plumber node',env='PLUMBER_SERVER_NODE_ID',required"
	NodeId string `` /* 192-byte string literal not displayed */
	// @gotags: kong:"default=aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaa,help='ID of the plumber cluster (has to be the same across all nodes)',env='PLUMBER_SERVER_CLUSTER_ID',required"
	ClusterId string `` /* 252-byte string literal not displayed */
	// @gotags: kong:"help='Host:port that the gRPC server will bind to',env='PLUMBER_SERVER_GRPC_LISTEN_ADDRESS',default=0.0.0.0:9090"
	GrpcListenAddress string `` /* 234-byte string literal not displayed */
	// @gotags: kong:"default=streamdal,help='All gRPC requests require this auth token to be set',env='PLUMBER_SERVER_AUTH_TOKEN',required"
	AuthToken string `` /* 213-byte string literal not displayed */
	// @gotags: kong:"help='Comma separated list of NATS server URLs (can contain user:password if using auth; only used if --enable-cluster is true)',env='PLUMBER_SERVER_NATS_URL',default='nats://localhost:4222'"
	NatsUrl []string `` /* 280-byte string literal not displayed */
	// @gotags: kong:"help='Whether to use TLS (only used if --enable-cluster is true)',env='PLUMBER_SERVER_USE_TLS'"
	UseTls bool `` /* 184-byte string literal not displayed */
	// @gotags: kong:"help='TLS client cert file (only used if --enable-cluster is true)',env='PLUMBER_SERVER_TLS_CERT_FILE'"
	TlsCertFile string `` /* 206-byte string literal not displayed */
	// @gotags: kong:"help='TLS client key file (only used if --enable-cluster is true)',env='PLUMBER_SERVER_TLS_KEY_FILE'"
	TlsKeyFile string `` /* 201-byte string literal not displayed */
	// @gotags: kong:"help='TLS CA certificate file (only used if --enable-cluster is true)',env='PLUMBER_SERVER_TLS_CA_FILE'"
	TlsCaFile string `` /* 201-byte string literal not displayed */
	// @gotags: kong:"help='Skip server cert verification (only used if --enable-cluster is true)',env='PLUMBER_SERVER_TLS_SKIP_VERIFY',default=false"
	TlsSkipVerify bool `` /* 238-byte string literal not displayed */
	// @gotags: kong:"help='Run plumber in cluster mode (will use NATS)',env='PLUMBER_SERVER_ENABLE_CLUSTER',default=false"
	EnableCluster bool `` /* 210-byte string literal not displayed */
	// @gotags: kong:"help='Location to store time-series data for counters',default='./.tsdata'"
	StatsDatabasePath string `` /* 197-byte string literal not displayed */
	// @gotags: kong:"help='How often to flush time-series data (in seconds) from memory to storage',default='60'"
	StatsFlushIntervalSeconds int32 `` /* 241-byte string literal not displayed */
	// @gotags: kong:"help='What address to bind the built-in HTTP server to',default='0.0.0.0:9191'"
	HttpListenAddress string `` /* 201-byte string literal not displayed */
	// @gotags: kong:"help='Allow plumber to be controlled from https://console.streamdal.com',env='PLUMBER_REMOTE_CONTROL_ENABLED',default=false"
	RemoteControlEnabled bool `` /* 256-byte string literal not displayed */
	// @gotags: kong:"help='Address of Streamdal Plumber remote control service',env='PLUMBER_REMOTE_CONTROL_ADDRESS',default='foreman.streamdal.com:443'"
	RemoteControlAddress string `` /* 263-byte string literal not displayed */
	// @gotags: kong:"help='Streamdal API token, needed to access remote control service',env='PLUMBER_REMOTE_CONTROL_API_TOKEN'"
	RemoteControlApiToken string `` /* 243-byte string literal not displayed */
	// @gotags: kong:"help='Connect to remote control server without TLS',default=false"
	RemoteControlDisableTls bool `` /* 209-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ServerOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ServerOptions.ProtoReflect.Descriptor instead.

func (*ServerOptions) GetAuthToken added in v0.0.49 

func (x *ServerOptions) GetAuthToken() string

func (*ServerOptions) GetClusterId added in v0.0.49 

func (x *ServerOptions) GetClusterId() string

func (*ServerOptions) GetEnableCluster added in v0.0.138 

func (x *ServerOptions) GetEnableCluster() bool

func (*ServerOptions) GetGrpcListenAddress added in v0.0.49 

func (x *ServerOptions) GetGrpcListenAddress() string

func (*ServerOptions) GetHttpListenAddress added in v0.0.134 

func (x *ServerOptions) GetHttpListenAddress() string

func (*ServerOptions) GetNatsUrl added in v0.0.137 

func (x *ServerOptions) GetNatsUrl() []string

func (*ServerOptions) GetNodeId added in v0.0.49 

func (x *ServerOptions) GetNodeId() string

func (*ServerOptions) GetRemoteControlAddress added in v0.0.154 

func (x *ServerOptions) GetRemoteControlAddress() string

func (*ServerOptions) GetRemoteControlApiToken added in v0.0.154 

func (x *ServerOptions) GetRemoteControlApiToken() string

func (*ServerOptions) GetRemoteControlDisableTls added in v0.0.154 

func (x *ServerOptions) GetRemoteControlDisableTls() bool

func (*ServerOptions) GetRemoteControlEnabled added in v0.0.154 

func (x *ServerOptions) GetRemoteControlEnabled() bool

func (*ServerOptions) GetStatsDatabasePath added in v0.0.92 

func (x *ServerOptions) GetStatsDatabasePath() string

func (*ServerOptions) GetStatsFlushIntervalSeconds added in v0.0.92 

func (x *ServerOptions) GetStatsFlushIntervalSeconds() int32

func (*ServerOptions) GetTlsCaFile added in v0.0.137 

func (x *ServerOptions) GetTlsCaFile() string

func (*ServerOptions) GetTlsCertFile added in v0.0.137 

func (x *ServerOptions) GetTlsCertFile() string

func (*ServerOptions) GetTlsKeyFile added in v0.0.137 

func (x *ServerOptions) GetTlsKeyFile() string

func (*ServerOptions) GetTlsSkipVerify added in v0.0.137 

func (x *ServerOptions) GetTlsSkipVerify() bool

func (*ServerOptions) GetUseTls added in v0.0.139 

func (x *ServerOptions) GetUseTls() bool

func (*ServerOptions) ProtoMessage added in v0.0.49 

func (*ServerOptions) ProtoMessage()

func (*ServerOptions) ProtoReflect added in v0.0.181 

func (x *ServerOptions) ProtoReflect() protoreflect.Message

func (*ServerOptions) Reset added in v0.0.49 

func (x *ServerOptions) Reset()

func (*ServerOptions) String added in v0.0.49 

func (x *ServerOptions) String() string

type StopOptions added in v0.0.143 

type StopOptions struct {

	// @gotags: kong:"cmd,help='Stop relay in plumber server'"
	Relay *StopRelayOptions `protobuf:"bytes,1,opt,name=relay,proto3" json:"relay,omitempty" kong:"cmd,help='Stop relay in plumber server'"`
	// @gotags: kong:"cmd,help='Stop tunnel in plumber server'"
	Tunnel *StopTunnelOptions `protobuf:"bytes,2,opt,name=tunnel,proto3" json:"tunnel,omitempty" kong:"cmd,help='Stop tunnel in plumber server'"`
	// contains filtered or unexported fields
}

func (*StopOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use StopOptions.ProtoReflect.Descriptor instead.

func (*StopOptions) GetRelay added in v0.0.143 

func (x *StopOptions) GetRelay() *StopRelayOptions

func (*StopOptions) GetTunnel added in v0.0.143 

func (x *StopOptions) GetTunnel() *StopTunnelOptions

func (*StopOptions) ProtoMessage added in v0.0.143 

func (*StopOptions) ProtoMessage()

func (*StopOptions) ProtoReflect added in v0.0.181 

func (x *StopOptions) ProtoReflect() protoreflect.Message

func (*StopOptions) Reset added in v0.0.143 

func (x *StopOptions) Reset()

func (*StopOptions) String added in v0.0.143 

func (x *StopOptions) String() string

type StopRelayOptions added in v0.0.143 

type StopRelayOptions struct {

	// @gotags: kong:"help='ID of the relay to stop',required=true"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the relay to stop',required=true"`
	// contains filtered or unexported fields
}

func (*StopRelayOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use StopRelayOptions.ProtoReflect.Descriptor instead.

func (*StopRelayOptions) GetId added in v0.0.143 

func (x *StopRelayOptions) GetId() string

func (*StopRelayOptions) ProtoMessage added in v0.0.143 

func (*StopRelayOptions) ProtoMessage()

func (*StopRelayOptions) ProtoReflect added in v0.0.181 

func (x *StopRelayOptions) ProtoReflect() protoreflect.Message

func (*StopRelayOptions) Reset added in v0.0.143 

func (x *StopRelayOptions) Reset()

func (*StopRelayOptions) String added in v0.0.143 

func (x *StopRelayOptions) String() string

type StopTunnelOptions added in v0.0.143 

type StopTunnelOptions struct {

	// @gotags: kong:"help='ID of the tunnel to stop',required=true"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" kong:"help='ID of the tunnel to stop',required=true"`
	// contains filtered or unexported fields
}

func (*StopTunnelOptions) Descriptor deprecated added in v0.0.143 

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

Deprecated: Use StopTunnelOptions.ProtoReflect.Descriptor instead.

func (*StopTunnelOptions) GetId added in v0.0.143 

func (x *StopTunnelOptions) GetId() string

func (*StopTunnelOptions) ProtoMessage added in v0.0.143 

func (*StopTunnelOptions) ProtoMessage()

func (*StopTunnelOptions) ProtoReflect added in v0.0.181 

func (x *StopTunnelOptions) ProtoReflect() protoreflect.Message

func (*StopTunnelOptions) Reset added in v0.0.143 

func (x *StopTunnelOptions) Reset()

func (*StopTunnelOptions) String added in v0.0.143 

func (x *StopTunnelOptions) String() string

type StreamdalArchiveOptions added in v0.0.175 

type StreamdalArchiveOptions struct {

	// @gotags: kong:"embed,cmd,help='Archive a replay'"
	Replay *StreamdalArchiveReplayOptions `protobuf:"bytes,1,opt,name=replay,proto3" json:"replay,omitempty" kong:"embed,cmd,help='Archive a replay'"`
	// contains filtered or unexported fields
}

func (*StreamdalArchiveOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalArchiveOptions.ProtoReflect.Descriptor instead.

func (*StreamdalArchiveOptions) GetReplay added in v0.0.175 

func (x *StreamdalArchiveOptions) GetReplay() *StreamdalArchiveReplayOptions

func (*StreamdalArchiveOptions) ProtoMessage added in v0.0.175 

func (*StreamdalArchiveOptions) ProtoMessage()

func (*StreamdalArchiveOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalArchiveOptions) ProtoReflect() protoreflect.Message

func (*StreamdalArchiveOptions) Reset added in v0.0.175 

func (x *StreamdalArchiveOptions) Reset()

func (*StreamdalArchiveOptions) String added in v0.0.175 

func (x *StreamdalArchiveOptions) String() string

type StreamdalArchiveReplayOptions added in v0.0.175 

type StreamdalArchiveReplayOptions struct {

	// @gotags: kong:"help='Replay ID to archive',required"
	ReplayId string `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamdalArchiveReplayOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalArchiveReplayOptions.ProtoReflect.Descriptor instead.

func (*StreamdalArchiveReplayOptions) GetReplayId added in v0.0.175 

func (x *StreamdalArchiveReplayOptions) GetReplayId() string

func (*StreamdalArchiveReplayOptions) ProtoMessage added in v0.0.175 

func (*StreamdalArchiveReplayOptions) ProtoMessage()

func (*StreamdalArchiveReplayOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalArchiveReplayOptions) ProtoReflect() protoreflect.Message

func (*StreamdalArchiveReplayOptions) Reset added in v0.0.175 

func (x *StreamdalArchiveReplayOptions) Reset()

func (*StreamdalArchiveReplayOptions) String added in v0.0.175 

func (x *StreamdalArchiveReplayOptions) String() string

type StreamdalCreateCollectionOptions added in v0.0.175 

type StreamdalCreateCollectionOptions struct {

	// @gotags: kong:"help='Friendly name for the collection',required"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" kong:"help='Friendly name for the collection',required"`
	// @gotags: kong:"help='Schema the collection will use (can be obtained running _plumber streamdal list schema_)',required"
	SchemaId string `` /* 197-byte string literal not displayed */
	// @gotags: kong:"help='Optional notes for the collection'"
	Notes string `protobuf:"bytes,3,opt,name=notes,proto3" json:"notes,omitempty" kong:"help='Optional notes for the collection'"`
	// @gotags: kong:"help='(Protobuf Schemas Only) Envelope Type (deep or shallow)',default='deep'"
	EnvelopeType string `` /* 182-byte string literal not displayed */
	// @gotags: kong:"help='(Protobuf Schemas Only) Envelope Message Name (Ex: events.MessageEnvelope)'"
	EnvelopeRootMessage string `` /* 209-byte string literal not displayed */
	// @gotags: kong:"help='(Shallow Envelope Protobuf Schemas Only) Payload Message Name (Ex: events.ShallowPayload)'"
	PayloadFieldMessage string `` /* 224-byte string literal not displayed */
	// @gotags: kong:"help='(Shallow Envelope Protobuf Schemas Only) Field ID containing the message encoded with Payload Message'"
	PayloadFieldId string `` /* 221-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamdalCreateCollectionOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalCreateCollectionOptions.ProtoReflect.Descriptor instead.

func (*StreamdalCreateCollectionOptions) GetEnvelopeRootMessage added in v0.0.175 

func (x *StreamdalCreateCollectionOptions) GetEnvelopeRootMessage() string

func (*StreamdalCreateCollectionOptions) GetEnvelopeType added in v0.0.175 

func (x *StreamdalCreateCollectionOptions) GetEnvelopeType() string

func (*StreamdalCreateCollectionOptions) GetName added in v0.0.175 

func (x *StreamdalCreateCollectionOptions) GetName() string

func (*StreamdalCreateCollectionOptions) GetNotes added in v0.0.175 

func (x *StreamdalCreateCollectionOptions) GetNotes() string

func (*StreamdalCreateCollectionOptions) GetPayloadFieldId added in v0.0.175 

func (x *StreamdalCreateCollectionOptions) GetPayloadFieldId() string

func (*StreamdalCreateCollectionOptions) GetPayloadFieldMessage added in v0.0.175 

func (x *StreamdalCreateCollectionOptions) GetPayloadFieldMessage() string

func (*StreamdalCreateCollectionOptions) GetSchemaId added in v0.0.175 

func (x *StreamdalCreateCollectionOptions) GetSchemaId() string

func (*StreamdalCreateCollectionOptions) ProtoMessage added in v0.0.175 

func (*StreamdalCreateCollectionOptions) ProtoMessage()

func (*StreamdalCreateCollectionOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalCreateCollectionOptions) ProtoReflect() protoreflect.Message

func (*StreamdalCreateCollectionOptions) Reset added in v0.0.175 

func (x *StreamdalCreateCollectionOptions) Reset()

func (*StreamdalCreateCollectionOptions) String added in v0.0.175 

func (x *StreamdalCreateCollectionOptions) String() string

type StreamdalCreateDestinationOptions added in v0.0.175 

type StreamdalCreateDestinationOptions struct {

	// @gotags: kong:"help='Friendly name to assign to the destination',required"
	Name string `` /* 127-byte string literal not displayed */
	// @gotags: kong:"help='Any notes to include with the destination'"
	Notes string `protobuf:"bytes,2,opt,name=notes,proto3" json:"notes,omitempty" kong:"help='Any notes to include with the destination'"`
	// Used internally by CLI
	// @gotags: kong:"-"
	XApiDestinationType string `` /* 131-byte string literal not displayed */
	// @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='RabbitMQ'"
	Rabbit *WriteGroupRabbitOptions `protobuf:"bytes,101,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='RabbitMQ'"`
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *WriteGroupKubeMQQueueOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='AWS Simple Queue System'"
	AwsSqs *WriteGroupAWSSQSOptions `protobuf:"bytes,103,opt,name=aws_sqs,json=awsSqs,proto3" json:"aws_sqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='HTTP Destination (POST)'"
	Http *HTTPDestination `protobuf:"bytes,104,opt,name=http,proto3" json:"http,omitempty" kong:"cmd,help='HTTP Destination (POST)'"`
	// contains filtered or unexported fields
}

func (*StreamdalCreateDestinationOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalCreateDestinationOptions.ProtoReflect.Descriptor instead.

func (*StreamdalCreateDestinationOptions) GetAwsSqs added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) GetAwsSqs() *WriteGroupAWSSQSOptions

func (*StreamdalCreateDestinationOptions) GetHttp added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) GetHttp() *HTTPDestination

func (*StreamdalCreateDestinationOptions) GetKafka added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) GetKafka() *WriteGroupKafkaOptions

func (*StreamdalCreateDestinationOptions) GetKubemqQueue added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) GetKubemqQueue() *WriteGroupKubeMQQueueOptions

func (*StreamdalCreateDestinationOptions) GetName added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) GetName() string

func (*StreamdalCreateDestinationOptions) GetNotes added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) GetNotes() string

func (*StreamdalCreateDestinationOptions) GetRabbit added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) GetRabbit() *WriteGroupRabbitOptions

func (*StreamdalCreateDestinationOptions) GetXApiDestinationType added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) GetXApiDestinationType() string

func (*StreamdalCreateDestinationOptions) ProtoMessage added in v0.0.175 

func (*StreamdalCreateDestinationOptions) ProtoMessage()

func (*StreamdalCreateDestinationOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalCreateDestinationOptions) ProtoReflect() protoreflect.Message

func (*StreamdalCreateDestinationOptions) Reset added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) Reset()

func (*StreamdalCreateDestinationOptions) String added in v0.0.175 

func (x *StreamdalCreateDestinationOptions) String() string

type StreamdalCreateOptions added in v0.0.175 

type StreamdalCreateOptions struct {

	// @gotags: kong:"cmd,help='Create a collection'"
	Collection *StreamdalCreateCollectionOptions `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty" kong:"cmd,help='Create a collection'"`
	// @gotags: kong:"cmd,help='Create a replay'"
	Replay *StreamdalCreateReplayOptions `protobuf:"bytes,2,opt,name=replay,proto3" json:"replay,omitempty" kong:"cmd,help='Create a replay'"`
	// @gotags: kong:"cmd,help='Create a destination'"
	Destination *StreamdalCreateDestinationOptions `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty" kong:"cmd,help='Create a destination'"`
	// contains filtered or unexported fields
}

func (*StreamdalCreateOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalCreateOptions.ProtoReflect.Descriptor instead.

func (*StreamdalCreateOptions) GetCollection added in v0.0.175 

func (x *StreamdalCreateOptions) GetCollection() *StreamdalCreateCollectionOptions

func (*StreamdalCreateOptions) GetDestination added in v0.0.175 

func (x *StreamdalCreateOptions) GetDestination() *StreamdalCreateDestinationOptions

func (*StreamdalCreateOptions) GetReplay added in v0.0.175 

func (x *StreamdalCreateOptions) GetReplay() *StreamdalCreateReplayOptions

func (*StreamdalCreateOptions) ProtoMessage added in v0.0.175 

func (*StreamdalCreateOptions) ProtoMessage()

func (*StreamdalCreateOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalCreateOptions) ProtoReflect() protoreflect.Message

func (*StreamdalCreateOptions) Reset added in v0.0.175 

func (x *StreamdalCreateOptions) Reset()

func (*StreamdalCreateOptions) String added in v0.0.175 

func (x *StreamdalCreateOptions) String() string

type StreamdalCreateReplayOptions added in v0.0.175 

type StreamdalCreateReplayOptions struct {

	// @gotags: kong:"help='Friendly name to assign to the replay',required"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" kong:"help='Friendly name to assign to the replay',required"`
	// @gotags: kong:"help='One-time/single or continuous replay (options: single, continuous)',type=pbenum,pbenum_lowercase,default=single"
	Type StreamdalReplayType `` /* 224-byte string literal not displayed */
	// @gotags: kong:"help='Notes to attach to the replay'"
	Notes string `protobuf:"bytes,3,opt,name=notes,proto3" json:"notes,omitempty" kong:"help='Notes to attach to the replay'"`
	// @gotags: kong:"help='Collection ID to replay from',required"
	CollectionId string `` /* 149-byte string literal not displayed */
	// @gotags: kong:"help='Destination ID to replay to',required"
	DestinationId string `` /* 151-byte string literal not displayed */
	// @gotags: kong:"help='Search query',default='*'"
	Query string `protobuf:"bytes,6,opt,name=query,proto3" json:"query,omitempty" kong:"help='Search query',default='*'"`
	// @gotags: kong:"help='Where to begin search (RFC3339 timestamp)',required"
	FromTimestamp string `` /* 165-byte string literal not displayed */
	// @gotags: kong:"help='Where to end search (RFC3339 timestamp)',required"
	ToTimestamp string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamdalCreateReplayOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalCreateReplayOptions.ProtoReflect.Descriptor instead.

func (*StreamdalCreateReplayOptions) GetCollectionId added in v0.0.175 

func (x *StreamdalCreateReplayOptions) GetCollectionId() string

func (*StreamdalCreateReplayOptions) GetDestinationId added in v0.0.175 

func (x *StreamdalCreateReplayOptions) GetDestinationId() string

func (*StreamdalCreateReplayOptions) GetFromTimestamp added in v0.0.175 

func (x *StreamdalCreateReplayOptions) GetFromTimestamp() string

func (*StreamdalCreateReplayOptions) GetName added in v0.0.175 

func (x *StreamdalCreateReplayOptions) GetName() string

func (*StreamdalCreateReplayOptions) GetNotes added in v0.0.175 

func (x *StreamdalCreateReplayOptions) GetNotes() string

func (*StreamdalCreateReplayOptions) GetQuery added in v0.0.175 

func (x *StreamdalCreateReplayOptions) GetQuery() string

func (*StreamdalCreateReplayOptions) GetToTimestamp added in v0.0.175 

func (x *StreamdalCreateReplayOptions) GetToTimestamp() string

func (*StreamdalCreateReplayOptions) GetType added in v0.0.175 

func (x *StreamdalCreateReplayOptions) GetType() StreamdalReplayType

func (*StreamdalCreateReplayOptions) ProtoMessage added in v0.0.175 

func (*StreamdalCreateReplayOptions) ProtoMessage()

func (*StreamdalCreateReplayOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalCreateReplayOptions) ProtoReflect() protoreflect.Message

func (*StreamdalCreateReplayOptions) Reset added in v0.0.175 

func (x *StreamdalCreateReplayOptions) Reset()

func (*StreamdalCreateReplayOptions) String added in v0.0.175 

func (x *StreamdalCreateReplayOptions) String() string

type StreamdalIntegrationOptions added in v0.0.185 

type StreamdalIntegrationOptions struct {

	// @gotags: kong:"help='Whether to enable Streamdal integration',group='Streamdal Integration (github.com/streamdal/streamdal)'"
	StreamdalIntegrationEnable bool `` /* 259-byte string literal not displayed */
	// @gotags: kong:"help='Streamdal integration server address',default='localhost:8082',group='Streamdal Integration (github.com/streamdal/streamdal)'"
	StreamdalIntegrationServerAddress string `` /* 303-byte string literal not displayed */
	// @gotags: kong:"help='Streamdal integration auth token',default='1234',group='Streamdal Integration (github.com/streamdal/streamdal)'"
	StreamdalIntegrationAuthToken string `` /* 277-byte string literal not displayed */
	// @gotags: kong:"help='Streamdal integration service name',group='Streamdal Integration (github.com/streamdal/streamdal)'"
	StreamdalIntegrationServiceName string `` /* 270-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamdalIntegrationOptions) Descriptor deprecated added in v0.0.185 

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

Deprecated: Use StreamdalIntegrationOptions.ProtoReflect.Descriptor instead.

func (*StreamdalIntegrationOptions) GetStreamdalIntegrationAuthToken added in v0.0.185 

func (x *StreamdalIntegrationOptions) GetStreamdalIntegrationAuthToken() string

func (*StreamdalIntegrationOptions) GetStreamdalIntegrationEnable added in v0.0.185 

func (x *StreamdalIntegrationOptions) GetStreamdalIntegrationEnable() bool

func (*StreamdalIntegrationOptions) GetStreamdalIntegrationServerAddress added in v0.0.185 

func (x *StreamdalIntegrationOptions) GetStreamdalIntegrationServerAddress() string

func (*StreamdalIntegrationOptions) GetStreamdalIntegrationServiceName added in v0.0.185 

func (x *StreamdalIntegrationOptions) GetStreamdalIntegrationServiceName() string

func (*StreamdalIntegrationOptions) ProtoMessage added in v0.0.185 

func (*StreamdalIntegrationOptions) ProtoMessage()

func (*StreamdalIntegrationOptions) ProtoReflect added in v0.0.185 

func (x *StreamdalIntegrationOptions) ProtoReflect() protoreflect.Message

func (*StreamdalIntegrationOptions) Reset added in v0.0.185 

func (x *StreamdalIntegrationOptions) Reset()

func (*StreamdalIntegrationOptions) String added in v0.0.185 

func (x *StreamdalIntegrationOptions) String() string

type StreamdalListCollectionOptions added in v0.0.175 

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

func (*StreamdalListCollectionOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalListCollectionOptions.ProtoReflect.Descriptor instead.

func (*StreamdalListCollectionOptions) ProtoMessage added in v0.0.175 

func (*StreamdalListCollectionOptions) ProtoMessage()

func (*StreamdalListCollectionOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalListCollectionOptions) ProtoReflect() protoreflect.Message

func (*StreamdalListCollectionOptions) Reset added in v0.0.175 

func (x *StreamdalListCollectionOptions) Reset()

func (*StreamdalListCollectionOptions) String added in v0.0.175 

func (x *StreamdalListCollectionOptions) String() string

type StreamdalListDestinationOptions added in v0.0.175 

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

func (*StreamdalListDestinationOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalListDestinationOptions.ProtoReflect.Descriptor instead.

func (*StreamdalListDestinationOptions) ProtoMessage added in v0.0.175 

func (*StreamdalListDestinationOptions) ProtoMessage()

func (*StreamdalListDestinationOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalListDestinationOptions) ProtoReflect() protoreflect.Message

func (*StreamdalListDestinationOptions) Reset added in v0.0.175 

func (x *StreamdalListDestinationOptions) Reset()

func (*StreamdalListDestinationOptions) String added in v0.0.175 

func (x *StreamdalListDestinationOptions) String() string

type StreamdalListOptions added in v0.0.175 

type StreamdalListOptions struct {

	// @gotags: kong:"cmd,help='List all collections'"
	Collection *StreamdalListCollectionOptions `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty" kong:"cmd,help='List all collections'"`
	// @gotags: kong:"cmd,help='List all destinations'"
	Destination *StreamdalListDestinationOptions `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty" kong:"cmd,help='List all destinations'"`
	// @gotags: kong:"cmd,help='List all replays'"
	Replay *StreamdalListReplayOptions `protobuf:"bytes,3,opt,name=replay,proto3" json:"replay,omitempty" kong:"cmd,help='List all replays'"`
	// @gotags: kong:"cmd,help='List all schemas'"
	Schema *StreamdalListSchemaOptions `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty" kong:"cmd,help='List all schemas'"`
	// contains filtered or unexported fields
}

func (*StreamdalListOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalListOptions.ProtoReflect.Descriptor instead.

func (*StreamdalListOptions) GetCollection added in v0.0.175 

func (x *StreamdalListOptions) GetCollection() *StreamdalListCollectionOptions

func (*StreamdalListOptions) GetDestination added in v0.0.175 

func (x *StreamdalListOptions) GetDestination() *StreamdalListDestinationOptions

func (*StreamdalListOptions) GetReplay added in v0.0.175 

func (x *StreamdalListOptions) GetReplay() *StreamdalListReplayOptions

func (*StreamdalListOptions) GetSchema added in v0.0.175 

func (x *StreamdalListOptions) GetSchema() *StreamdalListSchemaOptions

func (*StreamdalListOptions) ProtoMessage added in v0.0.175 

func (*StreamdalListOptions) ProtoMessage()

func (*StreamdalListOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalListOptions) ProtoReflect() protoreflect.Message

func (*StreamdalListOptions) Reset added in v0.0.175 

func (x *StreamdalListOptions) Reset()

func (*StreamdalListOptions) String added in v0.0.175 

func (x *StreamdalListOptions) String() string

type StreamdalListReplayOptions added in v0.0.175 

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

func (*StreamdalListReplayOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalListReplayOptions.ProtoReflect.Descriptor instead.

func (*StreamdalListReplayOptions) ProtoMessage added in v0.0.175 

func (*StreamdalListReplayOptions) ProtoMessage()

func (*StreamdalListReplayOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalListReplayOptions) ProtoReflect() protoreflect.Message

func (*StreamdalListReplayOptions) Reset added in v0.0.175 

func (x *StreamdalListReplayOptions) Reset()

func (*StreamdalListReplayOptions) String added in v0.0.175 

func (x *StreamdalListReplayOptions) String() string

type StreamdalListSchemaOptions added in v0.0.175 

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

func (*StreamdalListSchemaOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalListSchemaOptions.ProtoReflect.Descriptor instead.

func (*StreamdalListSchemaOptions) ProtoMessage added in v0.0.175 

func (*StreamdalListSchemaOptions) ProtoMessage()

func (*StreamdalListSchemaOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalListSchemaOptions) ProtoReflect() protoreflect.Message

func (*StreamdalListSchemaOptions) Reset added in v0.0.175 

func (x *StreamdalListSchemaOptions) Reset()

func (*StreamdalListSchemaOptions) String added in v0.0.175 

func (x *StreamdalListSchemaOptions) String() string

type StreamdalLoginOptions added in v0.0.175 

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

func (*StreamdalLoginOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalLoginOptions.ProtoReflect.Descriptor instead.

func (*StreamdalLoginOptions) ProtoMessage added in v0.0.175 

func (*StreamdalLoginOptions) ProtoMessage()

func (*StreamdalLoginOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalLoginOptions) ProtoReflect() protoreflect.Message

func (*StreamdalLoginOptions) Reset added in v0.0.175 

func (x *StreamdalLoginOptions) Reset()

func (*StreamdalLoginOptions) String added in v0.0.175 

func (x *StreamdalLoginOptions) String() string

type StreamdalLogoutOptions added in v0.0.175 

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

func (*StreamdalLogoutOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalLogoutOptions.ProtoReflect.Descriptor instead.

func (*StreamdalLogoutOptions) ProtoMessage added in v0.0.175 

func (*StreamdalLogoutOptions) ProtoMessage()

func (*StreamdalLogoutOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalLogoutOptions) ProtoReflect() protoreflect.Message

func (*StreamdalLogoutOptions) Reset added in v0.0.175 

func (x *StreamdalLogoutOptions) Reset()

func (*StreamdalLogoutOptions) String added in v0.0.175 

func (x *StreamdalLogoutOptions) String() string

type StreamdalOptions added in v0.0.175 

type StreamdalOptions struct {

	// @gotags: kong:"help='How to output results (options: table json)',default=table,type=pbenum,pbenum_lowercase"
	OutputType StreamdalOutputType `` /* 230-byte string literal not displayed */
	// @gotags: kong:"help='Alternative URL to use for Streamdal API',default='https://api.streamdal.com'"
	ApiUrl string `` /* 170-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Login to the Streamdal platform'"
	Login *StreamdalLoginOptions `protobuf:"bytes,3,opt,name=login,proto3" json:"login,omitempty" kong:"cmd,help='Login to the Streamdal platform'"`
	// @gotags: kong:"cmd,help='Login to Streamdal'"
	Logout *StreamdalLogoutOptions `protobuf:"bytes,4,opt,name=logout,proto3" json:"logout,omitempty" kong:"cmd,help='Login to Streamdal'"`
	// @gotags: kong:"cmd,help='List Streamdal resources'"
	List *StreamdalListOptions `protobuf:"bytes,5,opt,name=list,proto3" json:"list,omitempty" kong:"cmd,help='List Streamdal resources'"`
	// @gotags: kong:"cmd,help='Create operations'"
	Create *StreamdalCreateOptions `protobuf:"bytes,6,opt,name=create,proto3" json:"create,omitempty" kong:"cmd,help='Create operations'"`
	// @gotags: kong:"cmd,help='Search operations'"
	Search *StreamdalSearchOptions `protobuf:"bytes,7,opt,name=search,proto3" json:"search,omitempty" kong:"cmd,help='Search operations'"`
	// @gotags: kong:"cmd,help='Archive a resource'"
	Archive *StreamdalArchiveOptions `protobuf:"bytes,8,opt,name=archive,proto3" json:"archive,omitempty" kong:"cmd,help='Archive a resource'"`
	// contains filtered or unexported fields
}

func (*StreamdalOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalOptions.ProtoReflect.Descriptor instead.

func (*StreamdalOptions) GetApiUrl added in v0.0.175 

func (x *StreamdalOptions) GetApiUrl() string

func (*StreamdalOptions) GetArchive added in v0.0.175 

func (x *StreamdalOptions) GetArchive() *StreamdalArchiveOptions

func (*StreamdalOptions) GetCreate added in v0.0.175 

func (x *StreamdalOptions) GetCreate() *StreamdalCreateOptions

func (*StreamdalOptions) GetList added in v0.0.175 

func (x *StreamdalOptions) GetList() *StreamdalListOptions

func (*StreamdalOptions) GetLogin added in v0.0.175 

func (x *StreamdalOptions) GetLogin() *StreamdalLoginOptions

func (*StreamdalOptions) GetLogout added in v0.0.175 

func (x *StreamdalOptions) GetLogout() *StreamdalLogoutOptions

func (*StreamdalOptions) GetOutputType added in v0.0.175 

func (x *StreamdalOptions) GetOutputType() StreamdalOutputType

func (*StreamdalOptions) GetSearch added in v0.0.175 

func (x *StreamdalOptions) GetSearch() *StreamdalSearchOptions

func (*StreamdalOptions) ProtoMessage added in v0.0.175 

func (*StreamdalOptions) ProtoMessage()

func (*StreamdalOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalOptions) ProtoReflect() protoreflect.Message

func (*StreamdalOptions) Reset added in v0.0.175 

func (x *StreamdalOptions) Reset()

func (*StreamdalOptions) String added in v0.0.175 

func (x *StreamdalOptions) String() string

type StreamdalOutputType added in v0.0.175 

type StreamdalOutputType int32
const (
	StreamdalOutputType_TABLE StreamdalOutputType = 0
	StreamdalOutputType_JSON  StreamdalOutputType = 1
)

func (StreamdalOutputType) Descriptor added in v0.0.181 

func (StreamdalOutputType) Descriptor() protoreflect.EnumDescriptor

func (StreamdalOutputType) Enum added in v0.0.181 

func (x StreamdalOutputType) Enum() *StreamdalOutputType

func (StreamdalOutputType) EnumDescriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalOutputType.Descriptor instead.

func (StreamdalOutputType) Number added in v0.0.181 

func (x StreamdalOutputType) Number() protoreflect.EnumNumber

func (StreamdalOutputType) String added in v0.0.175 

func (x StreamdalOutputType) String() string

func (StreamdalOutputType) Type added in v0.0.181 

func (StreamdalOutputType) Type() protoreflect.EnumType

type StreamdalReplayType added in v0.0.175 

type StreamdalReplayType int32
const (
	StreamdalReplayType_SINGLE     StreamdalReplayType = 0
	StreamdalReplayType_CONTINUOUS StreamdalReplayType = 1
)

func (StreamdalReplayType) Descriptor added in v0.0.181 

func (StreamdalReplayType) Descriptor() protoreflect.EnumDescriptor

func (StreamdalReplayType) Enum added in v0.0.181 

func (x StreamdalReplayType) Enum() *StreamdalReplayType

func (StreamdalReplayType) EnumDescriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalReplayType.Descriptor instead.

func (StreamdalReplayType) Number added in v0.0.181 

func (x StreamdalReplayType) Number() protoreflect.EnumNumber

func (StreamdalReplayType) String added in v0.0.175 

func (x StreamdalReplayType) String() string

func (StreamdalReplayType) Type added in v0.0.181 

func (StreamdalReplayType) Type() protoreflect.EnumType

type StreamdalSearchOptions added in v0.0.175 

type StreamdalSearchOptions struct {

	// @gotags: kong:"help='Query to perform',default='*'"
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty" kong:"help='Query to perform',default='*'"`
	// @gotags: kong:"help='Collection id to query',required"
	CollectionId string `` /* 143-byte string literal not displayed */
	// @gotags: kong:"help='Which page to display',default=1"
	Page int32 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty" kong:"help='Which page to display',default=1"`
	// contains filtered or unexported fields
}

func (*StreamdalSearchOptions) Descriptor deprecated added in v0.0.175 

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

Deprecated: Use StreamdalSearchOptions.ProtoReflect.Descriptor instead.

func (*StreamdalSearchOptions) GetCollectionId added in v0.0.175 

func (x *StreamdalSearchOptions) GetCollectionId() string

func (*StreamdalSearchOptions) GetPage added in v0.0.175 

func (x *StreamdalSearchOptions) GetPage() int32

func (*StreamdalSearchOptions) GetQuery added in v0.0.175 

func (x *StreamdalSearchOptions) GetQuery() string

func (*StreamdalSearchOptions) ProtoMessage added in v0.0.175 

func (*StreamdalSearchOptions) ProtoMessage()

func (*StreamdalSearchOptions) ProtoReflect added in v0.0.181 

func (x *StreamdalSearchOptions) ProtoReflect() protoreflect.Message

func (*StreamdalSearchOptions) Reset added in v0.0.175 

func (x *StreamdalSearchOptions) Reset()

func (*StreamdalSearchOptions) String added in v0.0.175 

func (x *StreamdalSearchOptions) String() string

type TunnelGroupAWSKinesisOptions added in v0.0.142 

type TunnelGroupAWSKinesisOptions struct {

	// @gotags: kong:"embed"
	XConn *args.AWSKinesisConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.AWSKinesisWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*TunnelGroupAWSKinesisOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupAWSKinesisOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupAWSKinesisOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupAWSKinesisOptions) GetArgs() *args.AWSKinesisWriteArgs

func (*TunnelGroupAWSKinesisOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupAWSKinesisOptions) GetXConn() *args.AWSKinesisConn

func (*TunnelGroupAWSKinesisOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupAWSKinesisOptions) ProtoMessage()

func (*TunnelGroupAWSKinesisOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupAWSKinesisOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupAWSKinesisOptions) Reset added in v0.0.142 

func (x *TunnelGroupAWSKinesisOptions) Reset()

func (*TunnelGroupAWSKinesisOptions) String added in v0.0.142 

func (x *TunnelGroupAWSKinesisOptions) String() string

type TunnelGroupAWSSNSOptions added in v0.0.142 

type TunnelGroupAWSSNSOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupAWSSNSOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupAWSSNSOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupAWSSNSOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupAWSSNSOptions) GetArgs() *args.AWSSNSWriteArgs

func (*TunnelGroupAWSSNSOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupAWSSNSOptions) GetXConn() *args.AWSSNSConn

func (*TunnelGroupAWSSNSOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupAWSSNSOptions) ProtoMessage()

func (*TunnelGroupAWSSNSOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupAWSSNSOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupAWSSNSOptions) Reset added in v0.0.142 

func (x *TunnelGroupAWSSNSOptions) Reset()

func (*TunnelGroupAWSSNSOptions) String added in v0.0.142 

func (x *TunnelGroupAWSSNSOptions) String() string

type TunnelGroupAWSSQSOptions added in v0.0.142 

type TunnelGroupAWSSQSOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupAWSSQSOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupAWSSQSOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupAWSSQSOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupAWSSQSOptions) GetArgs() *args.AWSSQSWriteArgs

func (*TunnelGroupAWSSQSOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupAWSSQSOptions) GetXConn() *args.AWSSQSConn

func (*TunnelGroupAWSSQSOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupAWSSQSOptions) ProtoMessage()

func (*TunnelGroupAWSSQSOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupAWSSQSOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupAWSSQSOptions) Reset added in v0.0.142 

func (x *TunnelGroupAWSSQSOptions) Reset()

func (*TunnelGroupAWSSQSOptions) String added in v0.0.142 

func (x *TunnelGroupAWSSQSOptions) String() string

type TunnelGroupActiveMQOptions added in v0.0.142 

type TunnelGroupActiveMQOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupActiveMQOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupActiveMQOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupActiveMQOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupActiveMQOptions) GetArgs() *args.ActiveMQWriteArgs

func (*TunnelGroupActiveMQOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupActiveMQOptions) GetXConn() *args.ActiveMQConn

func (*TunnelGroupActiveMQOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupActiveMQOptions) ProtoMessage()

func (*TunnelGroupActiveMQOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupActiveMQOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupActiveMQOptions) Reset added in v0.0.142 

func (x *TunnelGroupActiveMQOptions) Reset()

func (*TunnelGroupActiveMQOptions) String added in v0.0.142 

func (x *TunnelGroupActiveMQOptions) String() string

type TunnelGroupAzureEventHubOptions added in v0.0.142 

type TunnelGroupAzureEventHubOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupAzureEventHubOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupAzureEventHubOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupAzureEventHubOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupAzureEventHubOptions) GetArgs() *args.AzureEventHubWriteArgs

func (*TunnelGroupAzureEventHubOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupAzureEventHubOptions) GetXConn() *args.AzureEventHubConn

func (*TunnelGroupAzureEventHubOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupAzureEventHubOptions) ProtoMessage()

func (*TunnelGroupAzureEventHubOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupAzureEventHubOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupAzureEventHubOptions) Reset added in v0.0.142 

func (x *TunnelGroupAzureEventHubOptions) Reset()

func (*TunnelGroupAzureEventHubOptions) String added in v0.0.142 

func (x *TunnelGroupAzureEventHubOptions) String() string

type TunnelGroupAzureServiceBusOptions added in v0.0.142 

type TunnelGroupAzureServiceBusOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupAzureServiceBusOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupAzureServiceBusOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupAzureServiceBusOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupAzureServiceBusOptions) GetArgs() *args.AzureServiceBusWriteArgs

func (*TunnelGroupAzureServiceBusOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupAzureServiceBusOptions) GetXConn() *args.AzureServiceBusConn

func (*TunnelGroupAzureServiceBusOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupAzureServiceBusOptions) ProtoMessage()

func (*TunnelGroupAzureServiceBusOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupAzureServiceBusOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupAzureServiceBusOptions) Reset added in v0.0.142 

func (x *TunnelGroupAzureServiceBusOptions) Reset()

func (*TunnelGroupAzureServiceBusOptions) String added in v0.0.142 

func (x *TunnelGroupAzureServiceBusOptions) String() string

type TunnelGroupGCPPubSubOptions added in v0.0.142 

type TunnelGroupGCPPubSubOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupGCPPubSubOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupGCPPubSubOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupGCPPubSubOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupGCPPubSubOptions) GetArgs() *args.GCPPubSubWriteArgs

func (*TunnelGroupGCPPubSubOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupGCPPubSubOptions) GetXConn() *args.GCPPubSubConn

func (*TunnelGroupGCPPubSubOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupGCPPubSubOptions) ProtoMessage()

func (*TunnelGroupGCPPubSubOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupGCPPubSubOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupGCPPubSubOptions) Reset added in v0.0.142 

func (x *TunnelGroupGCPPubSubOptions) Reset()

func (*TunnelGroupGCPPubSubOptions) String added in v0.0.142 

func (x *TunnelGroupGCPPubSubOptions) String() string

type TunnelGroupKafkaOptions added in v0.0.142 

type TunnelGroupKafkaOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupKafkaOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupKafkaOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupKafkaOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupKafkaOptions) GetArgs() *args.KafkaWriteArgs

func (*TunnelGroupKafkaOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupKafkaOptions) GetXConn() *args.KafkaConn

func (*TunnelGroupKafkaOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupKafkaOptions) ProtoMessage()

func (*TunnelGroupKafkaOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupKafkaOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupKafkaOptions) Reset added in v0.0.142 

func (x *TunnelGroupKafkaOptions) Reset()

func (*TunnelGroupKafkaOptions) String added in v0.0.142 

func (x *TunnelGroupKafkaOptions) String() string

type TunnelGroupKubeMQQueueOptions added in v0.0.142 

type TunnelGroupKubeMQQueueOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupKubeMQQueueOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupKubeMQQueueOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupKubeMQQueueOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupKubeMQQueueOptions) GetArgs() *args.KubeMQQueueWriteArgs

func (*TunnelGroupKubeMQQueueOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupKubeMQQueueOptions) GetXConn() *args.KubeMQQueueConn

func (*TunnelGroupKubeMQQueueOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupKubeMQQueueOptions) ProtoMessage()

func (*TunnelGroupKubeMQQueueOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupKubeMQQueueOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupKubeMQQueueOptions) Reset added in v0.0.142 

func (x *TunnelGroupKubeMQQueueOptions) Reset()

func (*TunnelGroupKubeMQQueueOptions) String added in v0.0.142 

func (x *TunnelGroupKubeMQQueueOptions) String() string

type TunnelGroupMQTTOptions added in v0.0.142 

type TunnelGroupMQTTOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupMQTTOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupMQTTOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupMQTTOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupMQTTOptions) GetArgs() *args.MQTTWriteArgs

func (*TunnelGroupMQTTOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupMQTTOptions) GetXConn() *args.MQTTConn

func (*TunnelGroupMQTTOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupMQTTOptions) ProtoMessage()

func (*TunnelGroupMQTTOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupMQTTOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupMQTTOptions) Reset added in v0.0.142 

func (x *TunnelGroupMQTTOptions) Reset()

func (*TunnelGroupMQTTOptions) String added in v0.0.142 

func (x *TunnelGroupMQTTOptions) String() string

type TunnelGroupMemphisOptions added in v0.0.177 

type TunnelGroupMemphisOptions struct {

	// @gotags: kong:"embed"
	XConn *args.MemphisConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.MemphisWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*TunnelGroupMemphisOptions) Descriptor deprecated added in v0.0.177 

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

Deprecated: Use TunnelGroupMemphisOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupMemphisOptions) GetArgs added in v0.0.177 

func (x *TunnelGroupMemphisOptions) GetArgs() *args.MemphisWriteArgs

func (*TunnelGroupMemphisOptions) GetXConn added in v0.0.177 

func (x *TunnelGroupMemphisOptions) GetXConn() *args.MemphisConn

func (*TunnelGroupMemphisOptions) ProtoMessage added in v0.0.177 

func (*TunnelGroupMemphisOptions) ProtoMessage()

func (*TunnelGroupMemphisOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupMemphisOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupMemphisOptions) Reset added in v0.0.177 

func (x *TunnelGroupMemphisOptions) Reset()

func (*TunnelGroupMemphisOptions) String added in v0.0.177 

func (x *TunnelGroupMemphisOptions) String() string

type TunnelGroupNSQOptions added in v0.0.142 

type TunnelGroupNSQOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupNSQOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupNSQOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupNSQOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupNSQOptions) GetArgs() *args.NSQWriteArgs

func (*TunnelGroupNSQOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupNSQOptions) GetXConn() *args.NSQConn

func (*TunnelGroupNSQOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupNSQOptions) ProtoMessage()

func (*TunnelGroupNSQOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupNSQOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupNSQOptions) Reset added in v0.0.142 

func (x *TunnelGroupNSQOptions) Reset()

func (*TunnelGroupNSQOptions) String added in v0.0.142 

func (x *TunnelGroupNSQOptions) String() string

type TunnelGroupNatsJetstreamOptions added in v0.0.142 

type TunnelGroupNatsJetstreamOptions struct {

	// @gotags: kong:"embed"
	XConn *args.NatsJetstreamConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.NatsJetstreamWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*TunnelGroupNatsJetstreamOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupNatsJetstreamOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupNatsJetstreamOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupNatsJetstreamOptions) GetArgs() *args.NatsJetstreamWriteArgs

func (*TunnelGroupNatsJetstreamOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupNatsJetstreamOptions) GetXConn() *args.NatsJetstreamConn

func (*TunnelGroupNatsJetstreamOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupNatsJetstreamOptions) ProtoMessage()

func (*TunnelGroupNatsJetstreamOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupNatsJetstreamOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupNatsJetstreamOptions) Reset added in v0.0.142 

func (x *TunnelGroupNatsJetstreamOptions) Reset()

func (*TunnelGroupNatsJetstreamOptions) String added in v0.0.142 

func (x *TunnelGroupNatsJetstreamOptions) String() string

type TunnelGroupNatsOptions added in v0.0.142 

type TunnelGroupNatsOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupNatsOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupNatsOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupNatsOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupNatsOptions) GetArgs() *args.NatsWriteArgs

func (*TunnelGroupNatsOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupNatsOptions) GetXConn() *args.NatsConn

func (*TunnelGroupNatsOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupNatsOptions) ProtoMessage()

func (*TunnelGroupNatsOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupNatsOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupNatsOptions) Reset added in v0.0.142 

func (x *TunnelGroupNatsOptions) Reset()

func (*TunnelGroupNatsOptions) String added in v0.0.142 

func (x *TunnelGroupNatsOptions) String() string

type TunnelGroupNatsStreamingOptions added in v0.0.142 

type TunnelGroupNatsStreamingOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupNatsStreamingOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupNatsStreamingOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupNatsStreamingOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupNatsStreamingOptions) GetArgs() *args.NatsStreamingWriteArgs

func (*TunnelGroupNatsStreamingOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupNatsStreamingOptions) GetXConn() *args.NatsStreamingConn

func (*TunnelGroupNatsStreamingOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupNatsStreamingOptions) ProtoMessage()

func (*TunnelGroupNatsStreamingOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupNatsStreamingOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupNatsStreamingOptions) Reset added in v0.0.142 

func (x *TunnelGroupNatsStreamingOptions) Reset()

func (*TunnelGroupNatsStreamingOptions) String added in v0.0.142 

func (x *TunnelGroupNatsStreamingOptions) String() string

type TunnelGroupPulsarOptions added in v0.0.142 

type TunnelGroupPulsarOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupPulsarOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupPulsarOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupPulsarOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupPulsarOptions) GetArgs() *args.PulsarWriteArgs

func (*TunnelGroupPulsarOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupPulsarOptions) GetXConn() *args.PulsarConn

func (*TunnelGroupPulsarOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupPulsarOptions) ProtoMessage()

func (*TunnelGroupPulsarOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupPulsarOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupPulsarOptions) Reset added in v0.0.142 

func (x *TunnelGroupPulsarOptions) Reset()

func (*TunnelGroupPulsarOptions) String added in v0.0.142 

func (x *TunnelGroupPulsarOptions) String() string

type TunnelGroupRabbitOptions added in v0.0.142 

type TunnelGroupRabbitOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupRabbitOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupRabbitOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupRabbitOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupRabbitOptions) GetArgs() *args.RabbitWriteArgs

func (*TunnelGroupRabbitOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupRabbitOptions) GetXConn() *args.RabbitConn

func (*TunnelGroupRabbitOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupRabbitOptions) ProtoMessage()

func (*TunnelGroupRabbitOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupRabbitOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupRabbitOptions) Reset added in v0.0.142 

func (x *TunnelGroupRabbitOptions) Reset()

func (*TunnelGroupRabbitOptions) String added in v0.0.142 

func (x *TunnelGroupRabbitOptions) String() string

type TunnelGroupRabbitStreamsOptions added in v0.0.142 

type TunnelGroupRabbitStreamsOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupRabbitStreamsOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupRabbitStreamsOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupRabbitStreamsOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupRabbitStreamsOptions) GetArgs() *args.RabbitStreamsWriteArgs

func (*TunnelGroupRabbitStreamsOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupRabbitStreamsOptions) GetXConn() *args.RabbitStreamsConn

func (*TunnelGroupRabbitStreamsOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupRabbitStreamsOptions) ProtoMessage()

func (*TunnelGroupRabbitStreamsOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupRabbitStreamsOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupRabbitStreamsOptions) Reset added in v0.0.142 

func (x *TunnelGroupRabbitStreamsOptions) Reset()

func (*TunnelGroupRabbitStreamsOptions) String added in v0.0.142 

func (x *TunnelGroupRabbitStreamsOptions) String() string

type TunnelGroupRedisPubSubOptions added in v0.0.142 

type TunnelGroupRedisPubSubOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupRedisPubSubOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupRedisPubSubOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupRedisPubSubOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupRedisPubSubOptions) GetArgs() *args.RedisPubSubWriteArgs

func (*TunnelGroupRedisPubSubOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupRedisPubSubOptions) GetXConn() *args.RedisPubSubConn

func (*TunnelGroupRedisPubSubOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupRedisPubSubOptions) ProtoMessage()

func (*TunnelGroupRedisPubSubOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupRedisPubSubOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupRedisPubSubOptions) Reset added in v0.0.142 

func (x *TunnelGroupRedisPubSubOptions) Reset()

func (*TunnelGroupRedisPubSubOptions) String added in v0.0.142 

func (x *TunnelGroupRedisPubSubOptions) String() string

type TunnelGroupRedisStreamsOptions added in v0.0.142 

type TunnelGroupRedisStreamsOptions 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"`
	// contains filtered or unexported fields
}

func (*TunnelGroupRedisStreamsOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelGroupRedisStreamsOptions.ProtoReflect.Descriptor instead.

func (*TunnelGroupRedisStreamsOptions) GetArgs added in v0.0.142 

func (x *TunnelGroupRedisStreamsOptions) GetArgs() *args.RedisStreamsWriteArgs

func (*TunnelGroupRedisStreamsOptions) GetXConn added in v0.0.142 

func (x *TunnelGroupRedisStreamsOptions) GetXConn() *args.RedisStreamsConn

func (*TunnelGroupRedisStreamsOptions) ProtoMessage added in v0.0.142 

func (*TunnelGroupRedisStreamsOptions) ProtoMessage()

func (*TunnelGroupRedisStreamsOptions) ProtoReflect added in v0.0.181 

func (x *TunnelGroupRedisStreamsOptions) ProtoReflect() protoreflect.Message

func (*TunnelGroupRedisStreamsOptions) Reset added in v0.0.142 

func (x *TunnelGroupRedisStreamsOptions) Reset()

func (*TunnelGroupRedisStreamsOptions) String added in v0.0.142 

func (x *TunnelGroupRedisStreamsOptions) String() string

type TunnelOptions added in v0.0.142 

type TunnelOptions struct {

	// @gotags: kong:"help='API token to use for tunnel (create here: https://console.streamdal.com/account/security)',required"
	ApiToken string `` /* 198-byte string literal not displayed */
	// @gotags: kong:"-"
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" kong:"-"`
	// @gotags: kong:"help='Tunnel API address',default='dproxy.streamdal.com:443'"
	XGrpcAddress string `` /* 164-byte string literal not displayed */
	// @gotags: kong:"help='Tunnel API initial connection timeout',default=5"
	XGrpcTimeoutSeconds uint32 `` /* 182-byte string literal not displayed */
	// @gotags: kong:"help='Use gRPC insecure mode when talking to Streamdal'"
	XGrpcInsecure bool `` /* 163-byte string literal not displayed */
	// Optional for server and CLI
	// NOTE: CLI-based tunnels will be treated as ephemeral.
	// @gotags: kong:"help='Name to identify tunnel in Streamdal console. If omitted, your IP address will be used'"
	Name string `` /* 162-byte string literal not displayed */
	// ID of the created tunnel; populated by plumber.
	// @gotags: kong:"-"
	XTunnelId string `protobuf:"bytes,1000,opt,name=_tunnel_id,json=TunnelId,proto3" json:"_tunnel_id,omitempty" kong:"-"`
	// Set by CreateTunnel() StopTunnel() and ResumeTunnel() methods in Plumber
	// @gotags: kong:"-"
	XActive bool `protobuf:"varint,1001,opt,name=_active,json=Active,proto3" json:"_active,omitempty" kong:"-"`
	// @gotags: kong:"cmd,help='Apache Kafka'"
	Kafka *TunnelGroupKafkaOptions `protobuf:"bytes,100,opt,name=kafka,proto3" json:"kafka,omitempty" kong:"cmd,help='Apache Kafka'"`
	// @gotags: kong:"cmd,help='Apache ActiveMQ'"
	Activemq *TunnelGroupActiveMQOptions `protobuf:"bytes,101,opt,name=activemq,proto3" json:"activemq,omitempty" kong:"cmd,help='Apache ActiveMQ'"`
	// @gotags: kong:"cmd,help='AWS Simple Queue System'"
	AwsSqs *TunnelGroupAWSSQSOptions `protobuf:"bytes,102,opt,name=aws_sqs,json=awsSqs,proto3" json:"aws_sqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='AWS Simple Notification System'"
	AwsSns *TunnelGroupAWSSNSOptions `` /* 130-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NATS'"
	Nats *TunnelGroupNatsOptions `protobuf:"bytes,104,opt,name=nats,proto3" json:"nats,omitempty" kong:"cmd,help='NATS'"`
	// @gotags: kong:"cmd,help='NATS Streaming'"
	NatsStreaming *TunnelGroupNatsStreamingOptions `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *TunnelGroupNSQOptions `protobuf:"bytes,106,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='RabbitMQ'"
	Rabbit *TunnelGroupRabbitOptions `protobuf:"bytes,107,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='RabbitMQ'"`
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *TunnelGroupMQTTOptions `protobuf:"bytes,108,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *TunnelGroupAzureServiceBusOptions `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Azure Event Hub'"
	AzureEventHub *TunnelGroupAzureEventHubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Google Cloud Platform Pub/Sub'"
	GcpPubsub *TunnelGroupGCPPubSubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *TunnelGroupKubeMQQueueOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *TunnelGroupRedisPubSubOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams *TunnelGroupRedisStreamsOptions `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Apache Pulsar'"
	Pulsar *TunnelGroupPulsarOptions `protobuf:"bytes,115,opt,name=pulsar,proto3" json:"pulsar,omitempty" kong:"cmd,help='Apache Pulsar'"`
	// @gotags: kong:"cmd,help='RabbitMQ Streams'"
	RabbitStreams *TunnelGroupRabbitStreamsOptions `` /* 137-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NATS JetStream'"
	NatsJetstream *TunnelGroupNatsJetstreamOptions `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='AWS Kinesis Streams'"
	AwsKinesis *TunnelGroupAWSKinesisOptions `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Memphis'"
	Memphis *TunnelGroupMemphisOptions `protobuf:"bytes,119,opt,name=memphis,proto3" json:"memphis,omitempty" kong:"cmd,help='Memphis'"`
	// contains filtered or unexported fields
}

func (*TunnelOptions) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use TunnelOptions.ProtoReflect.Descriptor instead.

func (*TunnelOptions) GetActivemq added in v0.0.142 

func (x *TunnelOptions) GetActivemq() *TunnelGroupActiveMQOptions

func (*TunnelOptions) GetApiToken added in v0.0.142 

func (x *TunnelOptions) GetApiToken() string

func (*TunnelOptions) GetAwsKinesis added in v0.0.142 

func (x *TunnelOptions) GetAwsKinesis() *TunnelGroupAWSKinesisOptions

func (*TunnelOptions) GetAwsSns added in v0.0.142 

func (x *TunnelOptions) GetAwsSns() *TunnelGroupAWSSNSOptions

func (*TunnelOptions) GetAwsSqs added in v0.0.142 

func (x *TunnelOptions) GetAwsSqs() *TunnelGroupAWSSQSOptions

func (*TunnelOptions) GetAzureEventHub added in v0.0.142 

func (x *TunnelOptions) GetAzureEventHub() *TunnelGroupAzureEventHubOptions

func (*TunnelOptions) GetAzureServiceBus added in v0.0.142 

func (x *TunnelOptions) GetAzureServiceBus() *TunnelGroupAzureServiceBusOptions

func (*TunnelOptions) GetConnectionId added in v0.0.142 

func (x *TunnelOptions) GetConnectionId() string

func (*TunnelOptions) GetGcpPubsub added in v0.0.142 

func (x *TunnelOptions) GetGcpPubsub() *TunnelGroupGCPPubSubOptions

func (*TunnelOptions) GetKafka added in v0.0.142 

func (x *TunnelOptions) GetKafka() *TunnelGroupKafkaOptions

func (*TunnelOptions) GetKubemqQueue added in v0.0.142 

func (x *TunnelOptions) GetKubemqQueue() *TunnelGroupKubeMQQueueOptions

func (*TunnelOptions) GetMemphis added in v0.0.177 

func (x *TunnelOptions) GetMemphis() *TunnelGroupMemphisOptions

func (*TunnelOptions) GetMqtt added in v0.0.142 

func (x *TunnelOptions) GetMqtt() *TunnelGroupMQTTOptions

func (*TunnelOptions) GetName added in v0.0.142 

func (x *TunnelOptions) GetName() string

func (*TunnelOptions) GetNats added in v0.0.142 

func (x *TunnelOptions) GetNats() *TunnelGroupNatsOptions

func (*TunnelOptions) GetNatsJetstream added in v0.0.142 

func (x *TunnelOptions) GetNatsJetstream() *TunnelGroupNatsJetstreamOptions

func (*TunnelOptions) GetNatsStreaming added in v0.0.142 

func (x *TunnelOptions) GetNatsStreaming() *TunnelGroupNatsStreamingOptions

func (*TunnelOptions) GetNsq added in v0.0.142 

func (x *TunnelOptions) GetNsq() *TunnelGroupNSQOptions

func (*TunnelOptions) GetPulsar added in v0.0.142 

func (x *TunnelOptions) GetPulsar() *TunnelGroupPulsarOptions

func (*TunnelOptions) GetRabbit added in v0.0.142 

func (x *TunnelOptions) GetRabbit() *TunnelGroupRabbitOptions

func (*TunnelOptions) GetRabbitStreams added in v0.0.142 

func (x *TunnelOptions) GetRabbitStreams() *TunnelGroupRabbitStreamsOptions

func (*TunnelOptions) GetRedisPubsub added in v0.0.142 

func (x *TunnelOptions) GetRedisPubsub() *TunnelGroupRedisPubSubOptions

func (*TunnelOptions) GetRedisStreams added in v0.0.142 

func (x *TunnelOptions) GetRedisStreams() *TunnelGroupRedisStreamsOptions

func (*TunnelOptions) GetXActive added in v0.0.142 

func (x *TunnelOptions) GetXActive() bool

func (*TunnelOptions) GetXGrpcAddress added in v0.0.142 

func (x *TunnelOptions) GetXGrpcAddress() string

func (*TunnelOptions) GetXGrpcInsecure added in v0.0.142 

func (x *TunnelOptions) GetXGrpcInsecure() bool

func (*TunnelOptions) GetXGrpcTimeoutSeconds added in v0.0.142 

func (x *TunnelOptions) GetXGrpcTimeoutSeconds() uint32

func (*TunnelOptions) GetXTunnelId added in v0.0.142 

func (x *TunnelOptions) GetXTunnelId() string

func (*TunnelOptions) ProtoMessage added in v0.0.142 

func (*TunnelOptions) ProtoMessage()

func (*TunnelOptions) ProtoReflect added in v0.0.181 

func (x *TunnelOptions) ProtoReflect() protoreflect.Message

func (*TunnelOptions) Reset added in v0.0.142 

func (x *TunnelOptions) Reset()

func (*TunnelOptions) String added in v0.0.142 

func (x *TunnelOptions) String() string

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 `` /* 213-byte string literal not displayed */
	// @gotags: kong:"-"
	InputStdin []string `protobuf:"bytes,3,rep,name=input_stdin,json=inputStdin,proto3" json:"input_stdin,omitempty" kong:"-"`
	// contains filtered or unexported fields
}

func (*WriteCLIOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteCLIOptions.ProtoReflect.Descriptor instead.

func (*WriteCLIOptions) GetInputAsJsonArray added in v0.0.49 

func (x *WriteCLIOptions) GetInputAsJsonArray() bool

func (*WriteCLIOptions) GetInputFile added in v0.0.49 

func (x *WriteCLIOptions) GetInputFile() string

func (*WriteCLIOptions) GetInputStdin added in v0.0.54 

func (x *WriteCLIOptions) GetInputStdin() []string

func (*WriteCLIOptions) ProtoMessage added in v0.0.49 

func (*WriteCLIOptions) ProtoMessage()

func (*WriteCLIOptions) ProtoReflect added in v0.0.181 

func (x *WriteCLIOptions) ProtoReflect() protoreflect.Message

func (*WriteCLIOptions) Reset added in v0.0.49 

func (x *WriteCLIOptions) Reset()

func (*WriteCLIOptions) String added in v0.0.49 

func (x *WriteCLIOptions) String() string

type WriteGroupAWSKinesisOptions added in v0.0.121 

type WriteGroupAWSKinesisOptions struct {

	// @gotags: kong:"embed"
	XConn *args.AWSKinesisConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.AWSKinesisWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*WriteGroupAWSKinesisOptions) Descriptor deprecated added in v0.0.121 

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

Deprecated: Use WriteGroupAWSKinesisOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupAWSKinesisOptions) GetArgs added in v0.0.121 

func (x *WriteGroupAWSKinesisOptions) GetArgs() *args.AWSKinesisWriteArgs

func (*WriteGroupAWSKinesisOptions) GetXConn added in v0.0.121 

func (x *WriteGroupAWSKinesisOptions) GetXConn() *args.AWSKinesisConn

func (*WriteGroupAWSKinesisOptions) ProtoMessage added in v0.0.121 

func (*WriteGroupAWSKinesisOptions) ProtoMessage()

func (*WriteGroupAWSKinesisOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupAWSKinesisOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupAWSKinesisOptions) Reset added in v0.0.121 

func (x *WriteGroupAWSKinesisOptions) Reset()

func (*WriteGroupAWSKinesisOptions) String added in v0.0.121 

func (x *WriteGroupAWSKinesisOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupAWSSNSOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupAWSSNSOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupAWSSNSOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupAWSSNSOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupAWSSNSOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAWSSNSOptions) ProtoMessage()

func (*WriteGroupAWSSNSOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupAWSSNSOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupAWSSNSOptions) Reset added in v0.0.49 

func (x *WriteGroupAWSSNSOptions) Reset()

func (*WriteGroupAWSSNSOptions) String added in v0.0.49 

func (x *WriteGroupAWSSNSOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupAWSSQSOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupAWSSQSOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupAWSSQSOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupAWSSQSOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupAWSSQSOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAWSSQSOptions) ProtoMessage()

func (*WriteGroupAWSSQSOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupAWSSQSOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupAWSSQSOptions) Reset added in v0.0.49 

func (x *WriteGroupAWSSQSOptions) Reset()

func (*WriteGroupAWSSQSOptions) String added in v0.0.49 

func (x *WriteGroupAWSSQSOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupActiveMQOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupActiveMQOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupActiveMQOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupActiveMQOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupActiveMQOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupActiveMQOptions) ProtoMessage()

func (*WriteGroupActiveMQOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupActiveMQOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupActiveMQOptions) Reset added in v0.0.49 

func (x *WriteGroupActiveMQOptions) Reset()

func (*WriteGroupActiveMQOptions) String added in v0.0.49 

func (x *WriteGroupActiveMQOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupAzureEventHubOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupAzureEventHubOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupAzureEventHubOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupAzureEventHubOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupAzureEventHubOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAzureEventHubOptions) ProtoMessage()

func (*WriteGroupAzureEventHubOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupAzureEventHubOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupAzureEventHubOptions) Reset added in v0.0.49 

func (x *WriteGroupAzureEventHubOptions) Reset()

func (*WriteGroupAzureEventHubOptions) String added in v0.0.49 

func (x *WriteGroupAzureEventHubOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupAzureServiceBusOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupAzureServiceBusOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupAzureServiceBusOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupAzureServiceBusOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupAzureServiceBusOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAzureServiceBusOptions) ProtoMessage()

func (*WriteGroupAzureServiceBusOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupAzureServiceBusOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupAzureServiceBusOptions) Reset added in v0.0.49 

func (x *WriteGroupAzureServiceBusOptions) Reset()

func (*WriteGroupAzureServiceBusOptions) String added in v0.0.49 

func (x *WriteGroupAzureServiceBusOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupGCPPubSubOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupGCPPubSubOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupGCPPubSubOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupGCPPubSubOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupGCPPubSubOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupGCPPubSubOptions) ProtoMessage()

func (*WriteGroupGCPPubSubOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupGCPPubSubOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupGCPPubSubOptions) Reset added in v0.0.49 

func (x *WriteGroupGCPPubSubOptions) Reset()

func (*WriteGroupGCPPubSubOptions) String added in v0.0.49 

func (x *WriteGroupGCPPubSubOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupKafkaOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupKafkaOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupKafkaOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupKafkaOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupKafkaOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupKafkaOptions) ProtoMessage()

func (*WriteGroupKafkaOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupKafkaOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupKafkaOptions) Reset added in v0.0.49 

func (x *WriteGroupKafkaOptions) Reset()

func (*WriteGroupKafkaOptions) String added in v0.0.49 

func (x *WriteGroupKafkaOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupKubeMQQueueOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupKubeMQQueueOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupKubeMQQueueOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupKubeMQQueueOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupKubeMQQueueOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupKubeMQQueueOptions) ProtoMessage()

func (*WriteGroupKubeMQQueueOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupKubeMQQueueOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupKubeMQQueueOptions) Reset added in v0.0.49 

func (x *WriteGroupKubeMQQueueOptions) Reset()

func (*WriteGroupKubeMQQueueOptions) String added in v0.0.49 

func (x *WriteGroupKubeMQQueueOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupMQTTOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupMQTTOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupMQTTOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupMQTTOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupMQTTOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupMQTTOptions) ProtoMessage()

func (*WriteGroupMQTTOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupMQTTOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupMQTTOptions) Reset added in v0.0.49 

func (x *WriteGroupMQTTOptions) Reset()

func (*WriteGroupMQTTOptions) String added in v0.0.49 

func (x *WriteGroupMQTTOptions) String() string

type WriteGroupMemphisOptions added in v0.0.177 

type WriteGroupMemphisOptions struct {

	// @gotags: kong:"embed"
	XConn *args.MemphisConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.MemphisWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*WriteGroupMemphisOptions) Descriptor deprecated added in v0.0.177 

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

Deprecated: Use WriteGroupMemphisOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupMemphisOptions) GetArgs added in v0.0.177 

func (x *WriteGroupMemphisOptions) GetArgs() *args.MemphisWriteArgs

func (*WriteGroupMemphisOptions) GetXConn added in v0.0.177 

func (x *WriteGroupMemphisOptions) GetXConn() *args.MemphisConn

func (*WriteGroupMemphisOptions) ProtoMessage added in v0.0.177 

func (*WriteGroupMemphisOptions) ProtoMessage()

func (*WriteGroupMemphisOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupMemphisOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupMemphisOptions) Reset added in v0.0.177 

func (x *WriteGroupMemphisOptions) Reset()

func (*WriteGroupMemphisOptions) String added in v0.0.177 

func (x *WriteGroupMemphisOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupNSQOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupNSQOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupNSQOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupNSQOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupNSQOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupNSQOptions) ProtoMessage()

func (*WriteGroupNSQOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupNSQOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupNSQOptions) Reset added in v0.0.49 

func (x *WriteGroupNSQOptions) Reset()

func (*WriteGroupNSQOptions) String added in v0.0.49 

func (x *WriteGroupNSQOptions) String() string

type WriteGroupNatsJetstreamOptions added in v0.0.119 

type WriteGroupNatsJetstreamOptions struct {

	// @gotags: kong:"embed"
	XConn *args.NatsJetstreamConn `protobuf:"bytes,1,opt,name=_conn,json=Conn,proto3" json:"_conn,omitempty" kong:"embed"`
	// @gotags: kong:"embed"
	Args *args.NatsJetstreamWriteArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*WriteGroupNatsJetstreamOptions) Descriptor deprecated added in v0.0.119 

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

Deprecated: Use WriteGroupNatsJetstreamOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupNatsJetstreamOptions) GetArgs added in v0.0.119 

func (x *WriteGroupNatsJetstreamOptions) GetArgs() *args.NatsJetstreamWriteArgs

func (*WriteGroupNatsJetstreamOptions) GetXConn added in v0.0.119 

func (x *WriteGroupNatsJetstreamOptions) GetXConn() *args.NatsJetstreamConn

func (*WriteGroupNatsJetstreamOptions) ProtoMessage added in v0.0.119 

func (*WriteGroupNatsJetstreamOptions) ProtoMessage()

func (*WriteGroupNatsJetstreamOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupNatsJetstreamOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupNatsJetstreamOptions) Reset added in v0.0.119 

func (x *WriteGroupNatsJetstreamOptions) Reset()

func (*WriteGroupNatsJetstreamOptions) String added in v0.0.119 

func (x *WriteGroupNatsJetstreamOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupNatsOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupNatsOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupNatsOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupNatsOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupNatsOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupNatsOptions) ProtoMessage()

func (*WriteGroupNatsOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupNatsOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupNatsOptions) Reset added in v0.0.49 

func (x *WriteGroupNatsOptions) Reset()

func (*WriteGroupNatsOptions) String added in v0.0.49 

func (x *WriteGroupNatsOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupNatsStreamingOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupNatsStreamingOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupNatsStreamingOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupNatsStreamingOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupNatsStreamingOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupNatsStreamingOptions) ProtoMessage()

func (*WriteGroupNatsStreamingOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupNatsStreamingOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupNatsStreamingOptions) Reset added in v0.0.49 

func (x *WriteGroupNatsStreamingOptions) Reset()

func (*WriteGroupNatsStreamingOptions) String added in v0.0.49 

func (x *WriteGroupNatsStreamingOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupPulsarOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupPulsarOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupPulsarOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupPulsarOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupPulsarOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupPulsarOptions) ProtoMessage()

func (*WriteGroupPulsarOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupPulsarOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupPulsarOptions) Reset added in v0.0.49 

func (x *WriteGroupPulsarOptions) Reset()

func (*WriteGroupPulsarOptions) String added in v0.0.49 

func (x *WriteGroupPulsarOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupRabbitOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupRabbitOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupRabbitOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupRabbitOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupRabbitOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRabbitOptions) ProtoMessage()

func (*WriteGroupRabbitOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupRabbitOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupRabbitOptions) Reset added in v0.0.49 

func (x *WriteGroupRabbitOptions) Reset()

func (*WriteGroupRabbitOptions) String added in v0.0.49 

func (x *WriteGroupRabbitOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupRabbitStreamsOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupRabbitStreamsOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupRabbitStreamsOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupRabbitStreamsOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupRabbitStreamsOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRabbitStreamsOptions) ProtoMessage()

func (*WriteGroupRabbitStreamsOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupRabbitStreamsOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupRabbitStreamsOptions) Reset added in v0.0.49 

func (x *WriteGroupRabbitStreamsOptions) Reset()

func (*WriteGroupRabbitStreamsOptions) String added in v0.0.49 

func (x *WriteGroupRabbitStreamsOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupRedisPubSubOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupRedisPubSubOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupRedisPubSubOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupRedisPubSubOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupRedisPubSubOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRedisPubSubOptions) ProtoMessage()

func (*WriteGroupRedisPubSubOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupRedisPubSubOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupRedisPubSubOptions) Reset added in v0.0.49 

func (x *WriteGroupRedisPubSubOptions) Reset()

func (*WriteGroupRedisPubSubOptions) String added in v0.0.49 

func (x *WriteGroupRedisPubSubOptions) String() string

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"`
	// contains filtered or unexported fields
}

func (*WriteGroupRedisStreamsOptions) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use WriteGroupRedisStreamsOptions.ProtoReflect.Descriptor instead.

func (*WriteGroupRedisStreamsOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupRedisStreamsOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupRedisStreamsOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRedisStreamsOptions) ProtoMessage()

func (*WriteGroupRedisStreamsOptions) ProtoReflect added in v0.0.181 

func (x *WriteGroupRedisStreamsOptions) ProtoReflect() protoreflect.Message

func (*WriteGroupRedisStreamsOptions) Reset added in v0.0.49 

func (x *WriteGroupRedisStreamsOptions) Reset()

func (*WriteGroupRedisStreamsOptions) String added in v0.0.49 

func (x *WriteGroupRedisStreamsOptions) String() string

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=aws_sqs,json=awsSqs,proto3" json:"aws_sqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='AWS Simple Notification System'"
	AwsSns *WriteGroupAWSSNSOptions `` /* 130-byte string literal not displayed */
	// @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 */
	// @gotags: kong:"cmd,help='NATS JetStream'"
	NatsJetstream *WriteGroupNatsJetstreamOptions `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='AWS Kinesis Streams'"
	AwsKinesis *WriteGroupAWSKinesisOptions `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Memphis'"
	Memphis *WriteGroupMemphisOptions `protobuf:"bytes,119,opt,name=memphis,proto3" json:"memphis,omitempty" kong:"cmd,help='Memphis'"`
	// contains filtered or unexported fields
}

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 deprecated added in v0.0.49 

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

Deprecated: Use WriteOptions.ProtoReflect.Descriptor instead.

func (*WriteOptions) GetActivemq added in v0.0.49 

func (x *WriteOptions) GetActivemq() *WriteGroupActiveMQOptions

func (*WriteOptions) GetAwsKinesis added in v0.0.121 

func (x *WriteOptions) GetAwsKinesis() *WriteGroupAWSKinesisOptions

func (*WriteOptions) GetAwsSns added in v0.0.114 

func (x *WriteOptions) GetAwsSns() *WriteGroupAWSSNSOptions

func (*WriteOptions) GetAwsSqs added in v0.0.114 

func (x *WriteOptions) GetAwsSqs() *WriteGroupAWSSQSOptions

func (*WriteOptions) GetAzureEventHub added in v0.0.49 

func (x *WriteOptions) GetAzureEventHub() *WriteGroupAzureEventHubOptions

func (*WriteOptions) GetAzureServiceBus added in v0.0.49 

func (x *WriteOptions) GetAzureServiceBus() *WriteGroupAzureServiceBusOptions

func (*WriteOptions) GetConnectionId added in v0.0.49 

func (x *WriteOptions) GetConnectionId() string

func (*WriteOptions) GetEncodeOptions added in v0.0.50 

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

func (*WriteOptions) GetGcpPubsub added in v0.0.49 

func (x *WriteOptions) GetGcpPubsub() *WriteGroupGCPPubSubOptions

func (*WriteOptions) GetKafka added in v0.0.49 

func (x *WriteOptions) GetKafka() *WriteGroupKafkaOptions

func (*WriteOptions) GetKubemqQueue added in v0.0.49 

func (x *WriteOptions) GetKubemqQueue() *WriteGroupKubeMQQueueOptions

func (*WriteOptions) GetMemphis added in v0.0.177 

func (x *WriteOptions) GetMemphis() *WriteGroupMemphisOptions

func (*WriteOptions) GetMqtt added in v0.0.49 

func (x *WriteOptions) GetMqtt() *WriteGroupMQTTOptions

func (*WriteOptions) GetNats added in v0.0.49 

func (x *WriteOptions) GetNats() *WriteGroupNatsOptions

func (*WriteOptions) GetNatsJetstream added in v0.0.119 

func (x *WriteOptions) GetNatsJetstream() *WriteGroupNatsJetstreamOptions

func (*WriteOptions) GetNatsStreaming added in v0.0.49 

func (x *WriteOptions) GetNatsStreaming() *WriteGroupNatsStreamingOptions

func (*WriteOptions) GetNsq added in v0.0.49 

func (x *WriteOptions) GetNsq() *WriteGroupNSQOptions

func (*WriteOptions) GetPulsar added in v0.0.49 

func (x *WriteOptions) GetPulsar() *WriteGroupPulsarOptions

func (*WriteOptions) GetRabbit added in v0.0.49 

func (x *WriteOptions) GetRabbit() *WriteGroupRabbitOptions

func (*WriteOptions) GetRabbitStreams added in v0.0.49 

func (x *WriteOptions) GetRabbitStreams() *WriteGroupRabbitStreamsOptions

func (*WriteOptions) GetRecord added in v0.0.49 

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

func (*WriteOptions) GetRedisPubsub added in v0.0.49 

func (x *WriteOptions) GetRedisPubsub() *WriteGroupRedisPubSubOptions

func (*WriteOptions) GetRedisStreams added in v0.0.49 

func (x *WriteOptions) GetRedisStreams() *WriteGroupRedisStreamsOptions

func (*WriteOptions) GetXCliOptions added in v0.0.49 

func (x *WriteOptions) GetXCliOptions() *WriteCLIOptions

func (*WriteOptions) ProtoMessage added in v0.0.49 

func (*WriteOptions) ProtoMessage()

func (*WriteOptions) ProtoReflect added in v0.0.181 

func (x *WriteOptions) ProtoReflect() protoreflect.Message

func (*WriteOptions) Reset added in v0.0.49 

func (x *WriteOptions) Reset()

func (*WriteOptions) String added in v0.0.49 

func (x *WriteOptions) String() string

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.