opts

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
}

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
}

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

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

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

type ConnectionOptions_AwsSqs struct {
	AwsSqs *args.AWSSQSConn `protobuf:"bytes,102,opt,name=aws_sqs,json=awsSqs,proto3,oneof"`
}

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

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

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

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

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

type ConnectionOptions_Memphis struct {
	Memphis *args.MemphisConn `protobuf:"bytes,121,opt,name=memphis,proto3,oneof"`
}

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

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

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

type ConnectionOptions_NatsJetstream struct {
	NatsJetstream *args.NatsJetstreamConn `protobuf:"bytes,119,opt,name=nats_jetstream,json=natsJetstream,proto3,oneof"`
}

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

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

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

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

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

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

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

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

type ConvertOption int32

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

type InferSchemaOptions_Type int32

type IsConnectionOptions_Conn = isConnectionOptions_Conn

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
}

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
}

type ReadFilterOptions struct {

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

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
}

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
}