opts

package
v0.0.99 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2021 License: Apache-2.0 Imports: 7 Imported by: 41

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BatchOutputType_name = map[int32]string{
	0: "TABLE",
	1: "JSON",
}
View Source 
var BatchOutputType_value = map[string]int32{
	"TABLE": 0,
	"JSON":  1,
}
View Source 
var BatchReplayType_name = map[int32]string{
	0: "SINGLE",
	1: "CONTINUOUS",
}
View Source 
var BatchReplayType_value = map[string]int32{
	"SINGLE":     0,
	"CONTINUOUS": 1,
}
View Source 
var ConvertOption_name = map[int32]string{
	0: "CONVERT_OPTION_UNSET",
	1: "CONVERT_OPTION_BASE64",
	2: "CONVERT_OPTION_GZIP",
}
View Source 
var ConvertOption_value = map[string]int32{
	"CONVERT_OPTION_UNSET":  0,
	"CONVERT_OPTION_BASE64": 1,
	"CONVERT_OPTION_GZIP":   2,
}
View Source 
var Counter_Resource_name = map[int32]string{
	0: "RESOURCE_UNSET",
	1: "RESOURCE_CONNECTION",
	2: "RESOURCE_READ",
	3: "RESOURCE_SCHEMA",
	4: "RESOURCE_REPLAY",
}
View Source 
var Counter_Resource_value = map[string]int32{
	"RESOURCE_UNSET":      0,
	"RESOURCE_CONNECTION": 1,
	"RESOURCE_READ":       2,
	"RESOURCE_SCHEMA":     3,
	"RESOURCE_REPLAY":     4,
}
View Source 
var Counter_Type_name = map[int32]string{
	0: "TYPE_UNSET",
	1: "TYPE_SCHEMA_VIOLATION",
	2: "TYPE_MESSAGE_RECEIVED",
	3: "TYPE_MESSAGE_REPLAYED",
}
View Source 
var Counter_Type_value = map[string]int32{
	"TYPE_UNSET":            0,
	"TYPE_SCHEMA_VIOLATION": 1,
	"TYPE_MESSAGE_RECEIVED": 2,
	"TYPE_MESSAGE_REPLAYED": 3,
}
View Source 
var InferSchemaOptions_Type_name = map[int32]string{
	0: "UNSET",
	1: "JSONSchema",
}
View Source 
var InferSchemaOptions_Type_value = map[string]int32{
	"UNSET":      0,
	"JSONSchema": 1,
}
View Source 
var MonitorServiceSchemaVersionType_name = map[int32]string{
	0: "SERVICE_SCHEMA_VERSION_CONDITION_TYPE_LATEST",
	1: "SERVICE_SCHEMA_VERSION_CONDITION_TYPE_EXACT",
}
View Source 
var MonitorServiceSchemaVersionType_value = map[string]int32{
	"SERVICE_SCHEMA_VERSION_CONDITION_TYPE_LATEST": 0,
	"SERVICE_SCHEMA_VERSION_CONDITION_TYPE_EXACT":  1,
}
View Source 
var ReadOperator_name = map[int32]string{
	0: "READ_OPERATOR_UNSET",
	1: "READ_OPERATOR_EQ",
	2: "READ_OPERATOR_LT",
	3: "READ_OPERATOR_GT",
	4: "READ_OPERATOR_LTE",
	5: "READ_OPERATOR_GTE",
}
View Source 
var ReadOperator_value = map[string]int32{
	"READ_OPERATOR_UNSET": 0,
	"READ_OPERATOR_EQ":    1,
	"READ_OPERATOR_LT":    2,
	"READ_OPERATOR_GT":    3,
	"READ_OPERATOR_LTE":   4,
	"READ_OPERATOR_GTE":   5,
}
View Source 
var Weekday_name = map[int32]string{
	0: "WEEKDAY_SUNDAY",
	1: "WEEKDAY_MONDAY",
	2: "WEEKDAY_TUESDAY",
	3: "WEEKDAY_WEDNESDAY",
	4: "WEEKDAY_THURSDAY",
	5: "WEEKDAY_FRIDAY",
	6: "WEEKDAY_SATURDAY",
}
View Source 
var Weekday_value = map[string]int32{
	"WEEKDAY_SUNDAY":    0,
	"WEEKDAY_MONDAY":    1,
	"WEEKDAY_TUESDAY":   2,
	"WEEKDAY_WEDNESDAY": 3,
	"WEEKDAY_THURSDAY":  4,
	"WEEKDAY_FRIDAY":    5,
	"WEEKDAY_SATURDAY":  6,
}

Functions

This section is empty.

Types

type AlertEmailOutput added in v0.0.84 

type AlertEmailOutput struct {
	EmailAddress []string          `protobuf:"bytes,1,rep,name=email_address,json=emailAddress,proto3" json:"email_address,omitempty"`
	Subject      string            `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	Metadata     map[string]string `` /* 157-byte string literal not displayed */
	// Optional
	SmtpServer           *AlertEmailOutput_SMTPServer `protobuf:"bytes,4,opt,name=smtp_server,json=smtpServer,proto3" json:"smtp_server,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*AlertEmailOutput) Descriptor added in v0.0.84 

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

func (*AlertEmailOutput) GetEmailAddress added in v0.0.84 

func (m *AlertEmailOutput) GetEmailAddress() []string

func (*AlertEmailOutput) GetMetadata added in v0.0.84 

func (m *AlertEmailOutput) GetMetadata() map[string]string

func (*AlertEmailOutput) GetSmtpServer added in v0.0.84 

func (m *AlertEmailOutput) GetSmtpServer() *AlertEmailOutput_SMTPServer

func (*AlertEmailOutput) GetSubject added in v0.0.84 

func (m *AlertEmailOutput) GetSubject() string

func (*AlertEmailOutput) ProtoMessage added in v0.0.84 

func (*AlertEmailOutput) ProtoMessage()

func (*AlertEmailOutput) Reset added in v0.0.84 

func (m *AlertEmailOutput) Reset()

func (*AlertEmailOutput) String added in v0.0.84 

func (m *AlertEmailOutput) String() string

func (*AlertEmailOutput) XXX_DiscardUnknown added in v0.0.84 

func (m *AlertEmailOutput) XXX_DiscardUnknown()

func (*AlertEmailOutput) XXX_Marshal added in v0.0.84 

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

func (*AlertEmailOutput) XXX_Merge added in v0.0.84 

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

func (*AlertEmailOutput) XXX_Size added in v0.0.84 

func (m *AlertEmailOutput) XXX_Size() int

func (*AlertEmailOutput) XXX_Unmarshal added in v0.0.84 

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

type AlertEmailOutput_SMTPServer added in v0.0.84 

type AlertEmailOutput_SMTPServer struct {
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Hostname             string   `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Port                 int32    `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	UseTls               bool     `protobuf:"varint,5,opt,name=use_tls,json=useTls,proto3" json:"use_tls,omitempty"`
	FromAddress          string   `protobuf:"bytes,6,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlertEmailOutput_SMTPServer) Descriptor added in v0.0.84 

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

func (*AlertEmailOutput_SMTPServer) GetFromAddress added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) GetFromAddress() string

func (*AlertEmailOutput_SMTPServer) GetHostname added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) GetHostname() string

func (*AlertEmailOutput_SMTPServer) GetPassword added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) GetPassword() string

func (*AlertEmailOutput_SMTPServer) GetPort added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) GetPort() int32

func (*AlertEmailOutput_SMTPServer) GetUseTls added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) GetUseTls() bool

func (*AlertEmailOutput_SMTPServer) GetUsername added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) GetUsername() string

func (*AlertEmailOutput_SMTPServer) ProtoMessage added in v0.0.84 

func (*AlertEmailOutput_SMTPServer) ProtoMessage()

func (*AlertEmailOutput_SMTPServer) Reset added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) Reset()

func (*AlertEmailOutput_SMTPServer) String added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) String() string

func (*AlertEmailOutput_SMTPServer) XXX_DiscardUnknown added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) XXX_DiscardUnknown()

func (*AlertEmailOutput_SMTPServer) XXX_Marshal added in v0.0.84 

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

func (*AlertEmailOutput_SMTPServer) XXX_Merge added in v0.0.84 

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

func (*AlertEmailOutput_SMTPServer) XXX_Size added in v0.0.84 

func (m *AlertEmailOutput_SMTPServer) XXX_Size() int

func (*AlertEmailOutput_SMTPServer) XXX_Unmarshal added in v0.0.84 

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

type AlertOptions added in v0.0.84 

type AlertOptions struct {
	MonitorIds []string       `protobuf:"bytes,1,rep,name=monitor_ids,json=monitorIds,proto3" json:"monitor_ids,omitempty"`
	Outputs    []*AlertOutput `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Optional (defaults to alert at all times)
	Schedule             *AlertSchedule `protobuf:"bytes,3,opt,name=schedule,proto3" json:"schedule,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AlertOptions) Descriptor added in v0.0.84 

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

func (*AlertOptions) GetMonitorIds added in v0.0.84 

func (m *AlertOptions) GetMonitorIds() []string

func (*AlertOptions) GetOutputs added in v0.0.84 

func (m *AlertOptions) GetOutputs() []*AlertOutput

func (*AlertOptions) GetSchedule added in v0.0.84 

func (m *AlertOptions) GetSchedule() *AlertSchedule

func (*AlertOptions) ProtoMessage added in v0.0.84 

func (*AlertOptions) ProtoMessage()

func (*AlertOptions) Reset added in v0.0.84 

func (m *AlertOptions) Reset()

func (*AlertOptions) String added in v0.0.84 

func (m *AlertOptions) String() string

func (*AlertOptions) XXX_DiscardUnknown added in v0.0.84 

func (m *AlertOptions) XXX_DiscardUnknown()

func (*AlertOptions) XXX_Marshal added in v0.0.84 

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

func (*AlertOptions) XXX_Merge added in v0.0.84 

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

func (*AlertOptions) XXX_Size added in v0.0.84 

func (m *AlertOptions) XXX_Size() int

func (*AlertOptions) XXX_Unmarshal added in v0.0.84 

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

type AlertOutput added in v0.0.84 

type AlertOutput struct {
	// Types that are valid to be assigned to Output:
	//	*AlertOutput_Email
	//	*AlertOutput_Slack
	//	*AlertOutput_Pagerduty
	Output               isAlertOutput_Output `protobuf_oneof:"output"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*AlertOutput) Descriptor added in v0.0.84 

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

func (*AlertOutput) GetEmail added in v0.0.84 

func (m *AlertOutput) GetEmail() *AlertEmailOutput

func (*AlertOutput) GetOutput added in v0.0.84 

func (m *AlertOutput) GetOutput() isAlertOutput_Output

func (*AlertOutput) GetPagerduty added in v0.0.84 

func (m *AlertOutput) GetPagerduty() *AlertPagerdutyOutput

func (*AlertOutput) GetSlack added in v0.0.84 

func (m *AlertOutput) GetSlack() *AlertSlackOutput

func (*AlertOutput) ProtoMessage added in v0.0.84 

func (*AlertOutput) ProtoMessage()

func (*AlertOutput) Reset added in v0.0.84 

func (m *AlertOutput) Reset()

func (*AlertOutput) String added in v0.0.84 

func (m *AlertOutput) String() string

func (*AlertOutput) XXX_DiscardUnknown added in v0.0.84 

func (m *AlertOutput) XXX_DiscardUnknown()

func (*AlertOutput) XXX_Marshal added in v0.0.84 

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

func (*AlertOutput) XXX_Merge added in v0.0.84 

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

func (*AlertOutput) XXX_OneofWrappers added in v0.0.84 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*AlertOutput) XXX_Size added in v0.0.84 

func (m *AlertOutput) XXX_Size() int

func (*AlertOutput) XXX_Unmarshal added in v0.0.84 

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

type AlertOutput_Email added in v0.0.84 

type AlertOutput_Email struct {
	Email *AlertEmailOutput `protobuf:"bytes,100,opt,name=email,proto3,oneof"`
}

type AlertOutput_Pagerduty added in v0.0.84 

type AlertOutput_Pagerduty struct {
	Pagerduty *AlertPagerdutyOutput `protobuf:"bytes,102,opt,name=pagerduty,proto3,oneof"`
}

type AlertOutput_Slack added in v0.0.84 

type AlertOutput_Slack struct {
	Slack *AlertSlackOutput `protobuf:"bytes,101,opt,name=slack,proto3,oneof"`
}

type AlertPagerdutyOutput added in v0.0.84 

type AlertPagerdutyOutput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlertPagerdutyOutput) Descriptor added in v0.0.84 

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

func (*AlertPagerdutyOutput) ProtoMessage added in v0.0.84 

func (*AlertPagerdutyOutput) ProtoMessage()

func (*AlertPagerdutyOutput) Reset added in v0.0.84 

func (m *AlertPagerdutyOutput) Reset()

func (*AlertPagerdutyOutput) String added in v0.0.84 

func (m *AlertPagerdutyOutput) String() string

func (*AlertPagerdutyOutput) XXX_DiscardUnknown added in v0.0.84 

func (m *AlertPagerdutyOutput) XXX_DiscardUnknown()

func (*AlertPagerdutyOutput) XXX_Marshal added in v0.0.84 

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

func (*AlertPagerdutyOutput) XXX_Merge added in v0.0.84 

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

func (*AlertPagerdutyOutput) XXX_Size added in v0.0.84 

func (m *AlertPagerdutyOutput) XXX_Size() int

func (*AlertPagerdutyOutput) XXX_Unmarshal added in v0.0.84 

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

type AlertSchedule added in v0.0.84 

type AlertSchedule struct {
	Timezone string `protobuf:"bytes,1,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// When to alert; at all times if unset
	TimeRangeOn []*AlertTimeRange `protobuf:"bytes,2,rep,name=time_range_on,json=timeRangeOn,proto3" json:"time_range_on,omitempty"`
	// When NOT to alert; never if unset
	TimeRangeOff         []*AlertTimeRange `protobuf:"bytes,3,rep,name=time_range_off,json=timeRangeOff,proto3" json:"time_range_off,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AlertSchedule) Descriptor added in v0.0.84 

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

func (*AlertSchedule) GetTimeRangeOff added in v0.0.84 

func (m *AlertSchedule) GetTimeRangeOff() []*AlertTimeRange

func (*AlertSchedule) GetTimeRangeOn added in v0.0.84 

func (m *AlertSchedule) GetTimeRangeOn() []*AlertTimeRange

func (*AlertSchedule) GetTimezone added in v0.0.84 

func (m *AlertSchedule) GetTimezone() string

func (*AlertSchedule) ProtoMessage added in v0.0.84 

func (*AlertSchedule) ProtoMessage()

func (*AlertSchedule) Reset added in v0.0.84 

func (m *AlertSchedule) Reset()

func (*AlertSchedule) String added in v0.0.84 

func (m *AlertSchedule) String() string

func (*AlertSchedule) XXX_DiscardUnknown added in v0.0.84 

func (m *AlertSchedule) XXX_DiscardUnknown()

func (*AlertSchedule) XXX_Marshal added in v0.0.84 

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

func (*AlertSchedule) XXX_Merge added in v0.0.84 

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

func (*AlertSchedule) XXX_Size added in v0.0.84 

func (m *AlertSchedule) XXX_Size() int

func (*AlertSchedule) XXX_Unmarshal added in v0.0.84 

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

type AlertSlackOutput added in v0.0.84 

type AlertSlackOutput struct {
	ChannelId            []string          `protobuf:"bytes,1,rep,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	AuthToken            string            `protobuf:"bytes,2,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AlertSlackOutput) Descriptor added in v0.0.84 

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

func (*AlertSlackOutput) GetAuthToken added in v0.0.84 

func (m *AlertSlackOutput) GetAuthToken() string

func (*AlertSlackOutput) GetChannelId added in v0.0.84 

func (m *AlertSlackOutput) GetChannelId() []string

func (*AlertSlackOutput) GetMetadata added in v0.0.84 

func (m *AlertSlackOutput) GetMetadata() map[string]string

func (*AlertSlackOutput) ProtoMessage added in v0.0.84 

func (*AlertSlackOutput) ProtoMessage()

func (*AlertSlackOutput) Reset added in v0.0.84 

func (m *AlertSlackOutput) Reset()

func (*AlertSlackOutput) String added in v0.0.84 

func (m *AlertSlackOutput) String() string

func (*AlertSlackOutput) XXX_DiscardUnknown added in v0.0.84 

func (m *AlertSlackOutput) XXX_DiscardUnknown()

func (*AlertSlackOutput) XXX_Marshal added in v0.0.84 

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

func (*AlertSlackOutput) XXX_Merge added in v0.0.84 

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

func (*AlertSlackOutput) XXX_Size added in v0.0.84 

func (m *AlertSlackOutput) XXX_Size() int

func (*AlertSlackOutput) XXX_Unmarshal added in v0.0.84 

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

type AlertTimeRange added in v0.0.84 

type AlertTimeRange struct {
	Days                 []Weekday `protobuf:"varint,1,rep,packed,name=days,proto3,enum=protos.opts.Weekday" json:"days,omitempty"`
	FromHour             uint32    `protobuf:"varint,2,opt,name=from_hour,json=fromHour,proto3" json:"from_hour,omitempty"`
	FromMin              uint32    `protobuf:"varint,3,opt,name=from_min,json=fromMin,proto3" json:"from_min,omitempty"`
	ToHour               uint32    `protobuf:"varint,4,opt,name=to_hour,json=toHour,proto3" json:"to_hour,omitempty"`
	ToMin                uint32    `protobuf:"varint,5,opt,name=to_min,json=toMin,proto3" json:"to_min,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*AlertTimeRange) Descriptor added in v0.0.84 

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

func (*AlertTimeRange) GetDays added in v0.0.84 

func (m *AlertTimeRange) GetDays() []Weekday

func (*AlertTimeRange) GetFromHour added in v0.0.84 

func (m *AlertTimeRange) GetFromHour() uint32

func (*AlertTimeRange) GetFromMin added in v0.0.84 

func (m *AlertTimeRange) GetFromMin() uint32

func (*AlertTimeRange) GetToHour added in v0.0.84 

func (m *AlertTimeRange) GetToHour() uint32

func (*AlertTimeRange) GetToMin added in v0.0.84 

func (m *AlertTimeRange) GetToMin() uint32

func (*AlertTimeRange) ProtoMessage added in v0.0.84 

func (*AlertTimeRange) ProtoMessage()

func (*AlertTimeRange) Reset added in v0.0.84 

func (m *AlertTimeRange) Reset()

func (*AlertTimeRange) String added in v0.0.84 

func (m *AlertTimeRange) String() string

func (*AlertTimeRange) XXX_DiscardUnknown added in v0.0.84 

func (m *AlertTimeRange) XXX_DiscardUnknown()

func (*AlertTimeRange) XXX_Marshal added in v0.0.84 

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

func (*AlertTimeRange) XXX_Merge added in v0.0.84 

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

func (*AlertTimeRange) XXX_Size added in v0.0.84 

func (m *AlertTimeRange) XXX_Size() int

func (*AlertTimeRange) XXX_Unmarshal added in v0.0.84 

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

type BatchArchiveOptions added in v0.0.54 

type BatchArchiveOptions struct {
	// @gotags: kong:"embed,cmd,help='Archive a replay'"
	Replay               *BatchArchiveReplayOptions `protobuf:"bytes,1,opt,name=replay,proto3" json:"replay,omitempty" kong:"embed,cmd,help='Archive a replay'"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*BatchArchiveOptions) Descriptor added in v0.0.54 

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

func (*BatchArchiveOptions) GetReplay added in v0.0.54 

func (m *BatchArchiveOptions) GetReplay() *BatchArchiveReplayOptions

func (*BatchArchiveOptions) ProtoMessage added in v0.0.54 

func (*BatchArchiveOptions) ProtoMessage()

func (*BatchArchiveOptions) Reset added in v0.0.54 

func (m *BatchArchiveOptions) Reset()

func (*BatchArchiveOptions) String added in v0.0.54 

func (m *BatchArchiveOptions) String() string

func (*BatchArchiveOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchArchiveOptions) XXX_DiscardUnknown()

func (*BatchArchiveOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchArchiveOptions) XXX_Merge added in v0.0.54 

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

func (*BatchArchiveOptions) XXX_Size added in v0.0.54 

func (m *BatchArchiveOptions) XXX_Size() int

func (*BatchArchiveOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchArchiveReplayOptions added in v0.0.54 

type BatchArchiveReplayOptions struct {
	// @gotags: kong:"help='Replay ID to archive',required"
	ReplayId             string   `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchArchiveReplayOptions) Descriptor added in v0.0.54 

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

func (*BatchArchiveReplayOptions) GetReplayId added in v0.0.54 

func (m *BatchArchiveReplayOptions) GetReplayId() string

func (*BatchArchiveReplayOptions) ProtoMessage added in v0.0.54 

func (*BatchArchiveReplayOptions) ProtoMessage()

func (*BatchArchiveReplayOptions) Reset added in v0.0.54 

func (m *BatchArchiveReplayOptions) Reset()

func (*BatchArchiveReplayOptions) String added in v0.0.54 

func (m *BatchArchiveReplayOptions) String() string

func (*BatchArchiveReplayOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchArchiveReplayOptions) XXX_DiscardUnknown()

func (*BatchArchiveReplayOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchArchiveReplayOptions) XXX_Merge added in v0.0.54 

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

func (*BatchArchiveReplayOptions) XXX_Size added in v0.0.54 

func (m *BatchArchiveReplayOptions) XXX_Size() int

func (*BatchArchiveReplayOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchCreateCollectionOptions added in v0.0.54 

type BatchCreateCollectionOptions 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 batch list schema_)',required"
	SchemaId string `` /* 193-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'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchCreateCollectionOptions) Descriptor added in v0.0.54 

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

func (*BatchCreateCollectionOptions) GetName added in v0.0.54 

func (m *BatchCreateCollectionOptions) GetName() string

func (*BatchCreateCollectionOptions) GetNotes added in v0.0.54 

func (m *BatchCreateCollectionOptions) GetNotes() string

func (*BatchCreateCollectionOptions) GetSchemaId added in v0.0.54 

func (m *BatchCreateCollectionOptions) GetSchemaId() string

func (*BatchCreateCollectionOptions) ProtoMessage added in v0.0.54 

func (*BatchCreateCollectionOptions) ProtoMessage()

func (*BatchCreateCollectionOptions) Reset added in v0.0.54 

func (m *BatchCreateCollectionOptions) Reset()

func (*BatchCreateCollectionOptions) String added in v0.0.54 

func (m *BatchCreateCollectionOptions) String() string

func (*BatchCreateCollectionOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchCreateCollectionOptions) XXX_DiscardUnknown()

func (*BatchCreateCollectionOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchCreateCollectionOptions) XXX_Merge added in v0.0.54 

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

func (*BatchCreateCollectionOptions) XXX_Size added in v0.0.54 

func (m *BatchCreateCollectionOptions) XXX_Size() int

func (*BatchCreateCollectionOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchCreateDestinationOptions added in v0.0.54 

type BatchCreateDestinationOptions 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=awssqs,proto3" json:"awssqs,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)'"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*BatchCreateDestinationOptions) Descriptor added in v0.0.54 

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

func (*BatchCreateDestinationOptions) GetAwssqs added in v0.0.54 

func (m *BatchCreateDestinationOptions) GetAwssqs() *WriteGroupAWSSQSOptions

func (*BatchCreateDestinationOptions) GetHttp added in v0.0.54 

func (m *BatchCreateDestinationOptions) GetHttp() *HTTPDestination

func (*BatchCreateDestinationOptions) GetKafka added in v0.0.54 

func (m *BatchCreateDestinationOptions) GetKafka() *WriteGroupKafkaOptions

func (*BatchCreateDestinationOptions) GetKubemqQueue added in v0.0.54 

func (m *BatchCreateDestinationOptions) GetKubemqQueue() *WriteGroupKubeMQQueueOptions

func (*BatchCreateDestinationOptions) GetName added in v0.0.54 

func (m *BatchCreateDestinationOptions) GetName() string

func (*BatchCreateDestinationOptions) GetNotes added in v0.0.54 

func (m *BatchCreateDestinationOptions) GetNotes() string

func (*BatchCreateDestinationOptions) GetRabbit added in v0.0.54 

func (m *BatchCreateDestinationOptions) GetRabbit() *WriteGroupRabbitOptions

func (*BatchCreateDestinationOptions) GetXApiDestinationType added in v0.0.54 

func (m *BatchCreateDestinationOptions) GetXApiDestinationType() string

func (*BatchCreateDestinationOptions) ProtoMessage added in v0.0.54 

func (*BatchCreateDestinationOptions) ProtoMessage()

func (*BatchCreateDestinationOptions) Reset added in v0.0.54 

func (m *BatchCreateDestinationOptions) Reset()

func (*BatchCreateDestinationOptions) String added in v0.0.54 

func (m *BatchCreateDestinationOptions) String() string

func (*BatchCreateDestinationOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchCreateDestinationOptions) XXX_DiscardUnknown()

func (*BatchCreateDestinationOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchCreateDestinationOptions) XXX_Merge added in v0.0.54 

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

func (*BatchCreateDestinationOptions) XXX_Size added in v0.0.54 

func (m *BatchCreateDestinationOptions) XXX_Size() int

func (*BatchCreateDestinationOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchCreateOptions added in v0.0.54 

type BatchCreateOptions struct {
	// @gotags: kong:"cmd,help='Create a collection'"
	Collection *BatchCreateCollectionOptions `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty" kong:"cmd,help='Create a collection'"`
	// @gotags: kong:"cmd,help='Create a replay'"
	Replay *BatchCreateReplayOptions `protobuf:"bytes,2,opt,name=replay,proto3" json:"replay,omitempty" kong:"cmd,help='Create a replay'"`
	// @gotags: kong:"cmd,help='Create a destination'"
	Destination          *BatchCreateDestinationOptions `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty" kong:"cmd,help='Create a destination'"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*BatchCreateOptions) Descriptor added in v0.0.54 

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

func (*BatchCreateOptions) GetCollection added in v0.0.54 

func (m *BatchCreateOptions) GetCollection() *BatchCreateCollectionOptions

func (*BatchCreateOptions) GetDestination added in v0.0.54 

func (m *BatchCreateOptions) GetDestination() *BatchCreateDestinationOptions

func (*BatchCreateOptions) GetReplay added in v0.0.54 

func (m *BatchCreateOptions) GetReplay() *BatchCreateReplayOptions

func (*BatchCreateOptions) ProtoMessage added in v0.0.54 

func (*BatchCreateOptions) ProtoMessage()

func (*BatchCreateOptions) Reset added in v0.0.54 

func (m *BatchCreateOptions) Reset()

func (*BatchCreateOptions) String added in v0.0.54 

func (m *BatchCreateOptions) String() string

func (*BatchCreateOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchCreateOptions) XXX_DiscardUnknown()

func (*BatchCreateOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchCreateOptions) XXX_Merge added in v0.0.54 

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

func (*BatchCreateOptions) XXX_Size added in v0.0.54 

func (m *BatchCreateOptions) XXX_Size() int

func (*BatchCreateOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchCreateReplayOptions added in v0.0.54 

type BatchCreateReplayOptions 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 BatchReplayType `` /* 220-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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchCreateReplayOptions) Descriptor added in v0.0.54 

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

func (*BatchCreateReplayOptions) GetCollectionId added in v0.0.54 

func (m *BatchCreateReplayOptions) GetCollectionId() string

func (*BatchCreateReplayOptions) GetDestinationId added in v0.0.54 

func (m *BatchCreateReplayOptions) GetDestinationId() string

func (*BatchCreateReplayOptions) GetFromTimestamp added in v0.0.54 

func (m *BatchCreateReplayOptions) GetFromTimestamp() string

func (*BatchCreateReplayOptions) GetName added in v0.0.54 

func (m *BatchCreateReplayOptions) GetName() string

func (*BatchCreateReplayOptions) GetNotes added in v0.0.54 

func (m *BatchCreateReplayOptions) GetNotes() string

func (*BatchCreateReplayOptions) GetQuery added in v0.0.54 

func (m *BatchCreateReplayOptions) GetQuery() string

func (*BatchCreateReplayOptions) GetToTimestamp added in v0.0.54 

func (m *BatchCreateReplayOptions) GetToTimestamp() string

func (*BatchCreateReplayOptions) GetType added in v0.0.54 

func (m *BatchCreateReplayOptions) GetType() BatchReplayType

func (*BatchCreateReplayOptions) ProtoMessage added in v0.0.54 

func (*BatchCreateReplayOptions) ProtoMessage()

func (*BatchCreateReplayOptions) Reset added in v0.0.54 

func (m *BatchCreateReplayOptions) Reset()

func (*BatchCreateReplayOptions) String added in v0.0.54 

func (m *BatchCreateReplayOptions) String() string

func (*BatchCreateReplayOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchCreateReplayOptions) XXX_DiscardUnknown()

func (*BatchCreateReplayOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchCreateReplayOptions) XXX_Merge added in v0.0.54 

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

func (*BatchCreateReplayOptions) XXX_Size added in v0.0.54 

func (m *BatchCreateReplayOptions) XXX_Size() int

func (*BatchCreateReplayOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchListOptions added in v0.0.54 

type BatchListOptions struct {
	// @gotags: kong:"cmd,help='List all collections'"
	Collection bool `protobuf:"varint,1,opt,name=collection,proto3" json:"collection,omitempty" kong:"cmd,help='List all collections'"`
	// @gotags: kong:"cmd,help='List all destinations'"
	Destination bool `protobuf:"varint,2,opt,name=destination,proto3" json:"destination,omitempty" kong:"cmd,help='List all destinations'"`
	// @gotags: kong:"cmd,help='List all replays'"
	Replay bool `protobuf:"varint,3,opt,name=replay,proto3" json:"replay,omitempty" kong:"cmd,help='List all replays'"`
	// @gotags: kong:"cmd,help='List all schemas'"
	Schema               bool     `protobuf:"varint,4,opt,name=schema,proto3" json:"schema,omitempty" kong:"cmd,help='List all schemas'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchListOptions) Descriptor added in v0.0.54 

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

func (*BatchListOptions) GetCollection added in v0.0.54 

func (m *BatchListOptions) GetCollection() bool

func (*BatchListOptions) GetDestination added in v0.0.54 

func (m *BatchListOptions) GetDestination() bool

func (*BatchListOptions) GetReplay added in v0.0.54 

func (m *BatchListOptions) GetReplay() bool

func (*BatchListOptions) GetSchema added in v0.0.54 

func (m *BatchListOptions) GetSchema() bool

func (*BatchListOptions) ProtoMessage added in v0.0.54 

func (*BatchListOptions) ProtoMessage()

func (*BatchListOptions) Reset added in v0.0.54 

func (m *BatchListOptions) Reset()

func (*BatchListOptions) String added in v0.0.54 

func (m *BatchListOptions) String() string

func (*BatchListOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchListOptions) XXX_DiscardUnknown()

func (*BatchListOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchListOptions) XXX_Merge added in v0.0.54 

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

func (*BatchListOptions) XXX_Size added in v0.0.54 

func (m *BatchListOptions) XXX_Size() int

func (*BatchListOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchLoginOptions added in v0.0.54 

type BatchLoginOptions struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchLoginOptions) Descriptor added in v0.0.54 

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

func (*BatchLoginOptions) ProtoMessage added in v0.0.54 

func (*BatchLoginOptions) ProtoMessage()

func (*BatchLoginOptions) Reset added in v0.0.54 

func (m *BatchLoginOptions) Reset()

func (*BatchLoginOptions) String added in v0.0.54 

func (m *BatchLoginOptions) String() string

func (*BatchLoginOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchLoginOptions) XXX_DiscardUnknown()

func (*BatchLoginOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchLoginOptions) XXX_Merge added in v0.0.54 

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

func (*BatchLoginOptions) XXX_Size added in v0.0.54 

func (m *BatchLoginOptions) XXX_Size() int

func (*BatchLoginOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchLogoutOptions added in v0.0.54 

type BatchLogoutOptions struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchLogoutOptions) Descriptor added in v0.0.54 

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

func (*BatchLogoutOptions) ProtoMessage added in v0.0.54 

func (*BatchLogoutOptions) ProtoMessage()

func (*BatchLogoutOptions) Reset added in v0.0.54 

func (m *BatchLogoutOptions) Reset()

func (*BatchLogoutOptions) String added in v0.0.54 

func (m *BatchLogoutOptions) String() string

func (*BatchLogoutOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchLogoutOptions) XXX_DiscardUnknown()

func (*BatchLogoutOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchLogoutOptions) XXX_Merge added in v0.0.54 

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

func (*BatchLogoutOptions) XXX_Size added in v0.0.54 

func (m *BatchLogoutOptions) XXX_Size() int

func (*BatchLogoutOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchOptions added in v0.0.54 

type BatchOptions struct {
	// @gotags: kong:"help='How to output results (options: table, json)',default=table,type=pbenum,pbenum_lowercase"
	OutputType BatchOutputType `` /* 227-byte string literal not displayed */
	// @gotags: kong:"help='Alternative URL to use for Batch API',default='https://api.batch.sh'"
	ApiUrl string `` /* 161-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Login to the Batch platform'"
	Login *BatchLoginOptions `protobuf:"bytes,3,opt,name=login,proto3" json:"login,omitempty" kong:"cmd,help='Login to the Batch platform'"`
	// @gotags: kong:"cmd,help='Login to Batch'"
	Logout *BatchLogoutOptions `protobuf:"bytes,4,opt,name=logout,proto3" json:"logout,omitempty" kong:"cmd,help='Login to Batch'"`
	// @gotags: kong:"cmd,help='List Batch resources'"
	List *BatchListOptions `protobuf:"bytes,5,opt,name=list,proto3" json:"list,omitempty" kong:"cmd,help='List Batch resources'"`
	// @gotags: kong:"cmd,help='Create operations'"
	Create *BatchCreateOptions `protobuf:"bytes,6,opt,name=create,proto3" json:"create,omitempty" kong:"cmd,help='Create operations'"`
	// @gotags: kong:"cmd,help='Search operations'"
	Search *BatchSearchOptions `protobuf:"bytes,7,opt,name=search,proto3" json:"search,omitempty" kong:"cmd,help='Search operations'"`
	// @gotags: kong:"cmd,help='Archive a resource'"
	Archive              *BatchArchiveOptions `protobuf:"bytes,8,opt,name=archive,proto3" json:"archive,omitempty" kong:"cmd,help='Archive a resource'"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*BatchOptions) Descriptor added in v0.0.54 

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

func (*BatchOptions) GetApiUrl added in v0.0.54 

func (m *BatchOptions) GetApiUrl() string

func (*BatchOptions) GetArchive added in v0.0.54 

func (m *BatchOptions) GetArchive() *BatchArchiveOptions

func (*BatchOptions) GetCreate added in v0.0.54 

func (m *BatchOptions) GetCreate() *BatchCreateOptions

func (*BatchOptions) GetList added in v0.0.54 

func (m *BatchOptions) GetList() *BatchListOptions

func (*BatchOptions) GetLogin added in v0.0.54 

func (m *BatchOptions) GetLogin() *BatchLoginOptions

func (*BatchOptions) GetLogout added in v0.0.54 

func (m *BatchOptions) GetLogout() *BatchLogoutOptions

func (*BatchOptions) GetOutputType added in v0.0.54 

func (m *BatchOptions) GetOutputType() BatchOutputType

func (*BatchOptions) GetSearch added in v0.0.54 

func (m *BatchOptions) GetSearch() *BatchSearchOptions

func (*BatchOptions) ProtoMessage added in v0.0.54 

func (*BatchOptions) ProtoMessage()

func (*BatchOptions) Reset added in v0.0.54 

func (m *BatchOptions) Reset()

func (*BatchOptions) String added in v0.0.54 

func (m *BatchOptions) String() string

func (*BatchOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchOptions) XXX_DiscardUnknown()

func (*BatchOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchOptions) XXX_Merge added in v0.0.54 

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

func (*BatchOptions) XXX_Size added in v0.0.54 

func (m *BatchOptions) XXX_Size() int

func (*BatchOptions) XXX_Unmarshal added in v0.0.54 

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

type BatchOutputType added in v0.0.54 

type BatchOutputType int32
const (
	BatchOutputType_TABLE BatchOutputType = 0
	BatchOutputType_JSON  BatchOutputType = 1
)

func (BatchOutputType) EnumDescriptor added in v0.0.54 

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

func (BatchOutputType) String added in v0.0.54 

func (x BatchOutputType) String() string

type BatchReplayType added in v0.0.54 

type BatchReplayType int32
const (
	BatchReplayType_SINGLE     BatchReplayType = 0
	BatchReplayType_CONTINUOUS BatchReplayType = 1
)

func (BatchReplayType) EnumDescriptor added in v0.0.54 

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

func (BatchReplayType) String added in v0.0.54 

func (x BatchReplayType) String() string

type BatchSearchOptions added in v0.0.54 

type BatchSearchOptions 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchSearchOptions) Descriptor added in v0.0.54 

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

func (*BatchSearchOptions) GetCollectionId added in v0.0.54 

func (m *BatchSearchOptions) GetCollectionId() string

func (*BatchSearchOptions) GetPage added in v0.0.54 

func (m *BatchSearchOptions) GetPage() int32

func (*BatchSearchOptions) GetQuery added in v0.0.54 

func (m *BatchSearchOptions) GetQuery() string

func (*BatchSearchOptions) ProtoMessage added in v0.0.54 

func (*BatchSearchOptions) ProtoMessage()

func (*BatchSearchOptions) Reset added in v0.0.54 

func (m *BatchSearchOptions) Reset()

func (*BatchSearchOptions) String added in v0.0.54 

func (m *BatchSearchOptions) String() string

func (*BatchSearchOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *BatchSearchOptions) XXX_DiscardUnknown()

func (*BatchSearchOptions) XXX_Marshal added in v0.0.54 

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

func (*BatchSearchOptions) XXX_Merge added in v0.0.54 

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

func (*BatchSearchOptions) XXX_Size added in v0.0.54 

func (m *BatchSearchOptions) XXX_Size() int

func (*BatchSearchOptions) XXX_Unmarshal added in v0.0.54 

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

type CLIOptions added in v0.0.51 

type CLIOptions struct {
	// @gotags: kong:"embed"
	Global *GlobalCLIOptions `protobuf:"bytes,1,opt,name=global,proto3" json:"global,omitempty" kong:"embed"`
	// @gotags: kong:"cmd,help='Read message(s) from messaging system'"
	Read *ReadOptions `protobuf:"bytes,2,opt,name=read,proto3" json:"read,omitempty" kong:"cmd,help='Read message(s) from messaging system'"`
	// @gotags: kong:"cmd,help='Write message(s) to messaging system'"
	Write *WriteOptions `protobuf:"bytes,3,opt,name=write,proto3" json:"write,omitempty" kong:"cmd,help='Write message(s) to messaging system'"`
	// @gotags: kong:"cmd,help='Relay message(s) from messaging system to Batch'"
	Relay *RelayOptions `` /* 129-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Use plumber as a replay destination in Batch.sh'"
	Dynamic *DynamicOptions `` /* 133-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Control Batch resources via the public API'"
	Batch *BatchOptions `protobuf:"bytes,6,opt,name=batch,proto3" json:"batch,omitempty" kong:"cmd,help='Control Batch resources via the public API'"`
	// @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'"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

For more info, check README_CLI.md

func (*CLIOptions) Descriptor added in v0.0.51 

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

func (*CLIOptions) GetBatch added in v0.0.54 

func (m *CLIOptions) GetBatch() *BatchOptions

func (*CLIOptions) GetDynamic added in v0.0.54 

func (m *CLIOptions) GetDynamic() *DynamicOptions

func (*CLIOptions) GetGlobal added in v0.0.51 

func (m *CLIOptions) GetGlobal() *GlobalCLIOptions

func (*CLIOptions) GetRead added in v0.0.51 

func (m *CLIOptions) GetRead() *ReadOptions

func (*CLIOptions) GetRelay added in v0.0.51 

func (m *CLIOptions) GetRelay() *RelayOptions

func (*CLIOptions) GetServer added in v0.0.51 

func (m *CLIOptions) GetServer() *ServerOptions

func (*CLIOptions) GetWrite added in v0.0.51 

func (m *CLIOptions) GetWrite() *WriteOptions

func (*CLIOptions) ProtoMessage added in v0.0.51 

func (*CLIOptions) ProtoMessage()

func (*CLIOptions) Reset added in v0.0.51 

func (m *CLIOptions) Reset()

func (*CLIOptions) String added in v0.0.51 

func (m *CLIOptions) String() string

func (*CLIOptions) XXX_DiscardUnknown added in v0.0.51 

func (m *CLIOptions) XXX_DiscardUnknown()

func (*CLIOptions) XXX_Marshal added in v0.0.51 

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

func (*CLIOptions) XXX_Merge added in v0.0.51 

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

func (*CLIOptions) XXX_Size added in v0.0.51 

func (m *CLIOptions) XXX_Size() int

func (*CLIOptions) XXX_Unmarshal added in v0.0.51 

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

type ConnectionOptions added in v0.0.49 

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

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

func (*ConnectionOptions) Descriptor added in v0.0.49 

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

func (*ConnectionOptions) GetActiveMq added in v0.0.49 

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

func (*ConnectionOptions) GetAwssns added in v0.0.49 

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

func (*ConnectionOptions) GetAwssqs added in v0.0.49 

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

func (*ConnectionOptions) GetAzureEventHub added in v0.0.49 

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

func (*ConnectionOptions) GetAzureServiceBus added in v0.0.49 

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

func (*ConnectionOptions) GetConn added in v0.0.49 

func (m *ConnectionOptions) GetConn() isConnectionOptions_Conn

func (*ConnectionOptions) GetGcpPubsub added in v0.0.49 

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

func (*ConnectionOptions) GetKafka added in v0.0.49 

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

func (*ConnectionOptions) GetKubemqQueue added in v0.0.49 

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

func (*ConnectionOptions) GetMongo added in v0.0.49 

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

func (*ConnectionOptions) GetMqtt added in v0.0.49 

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

func (*ConnectionOptions) GetName added in v0.0.49 

func (m *ConnectionOptions) GetName() string

func (*ConnectionOptions) GetNats added in v0.0.49 

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

func (*ConnectionOptions) GetNatsStreaming added in v0.0.49 

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

func (*ConnectionOptions) GetNotes added in v0.0.49 

func (m *ConnectionOptions) GetNotes() string

func (*ConnectionOptions) GetNsq added in v0.0.49 

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

func (*ConnectionOptions) GetPostgres added in v0.0.49 

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

func (*ConnectionOptions) GetPulsar added in v0.0.49 

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

func (*ConnectionOptions) GetRabbit added in v0.0.49 

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

func (*ConnectionOptions) GetRabbitStreams added in v0.0.49 

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

func (*ConnectionOptions) GetRedisPubsub added in v0.0.49 

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

func (*ConnectionOptions) GetRedisStreams added in v0.0.49 

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

func (*ConnectionOptions) GetXId added in v0.0.49 

func (m *ConnectionOptions) GetXId() string

func (*ConnectionOptions) ProtoMessage added in v0.0.49 

func (*ConnectionOptions) ProtoMessage()

func (*ConnectionOptions) Reset added in v0.0.49 

func (m *ConnectionOptions) Reset()

func (*ConnectionOptions) String added in v0.0.49 

func (m *ConnectionOptions) String() string

func (*ConnectionOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ConnectionOptions) XXX_DiscardUnknown()

func (*ConnectionOptions) XXX_Marshal added in v0.0.49 

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

func (*ConnectionOptions) XXX_Merge added in v0.0.49 

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

func (*ConnectionOptions) XXX_OneofWrappers added in v0.0.49 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConnectionOptions) XXX_Size added in v0.0.49 

func (m *ConnectionOptions) XXX_Size() int

func (*ConnectionOptions) XXX_Unmarshal added in v0.0.49 

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

type ConnectionOptions_ActiveMq added in v0.0.49 

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

type ConnectionOptions_Awssns added in v0.0.49 

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

type ConnectionOptions_Awssqs added in v0.0.49 

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

type ConnectionOptions_AzureEventHub added in v0.0.49 

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

type ConnectionOptions_AzureServiceBus added in v0.0.49 

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

type ConnectionOptions_GcpPubsub added in v0.0.49 

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

type ConnectionOptions_Kafka added in v0.0.49 

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

type ConnectionOptions_KubemqQueue added in v0.0.49 

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

type ConnectionOptions_Mongo added in v0.0.49 

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

type ConnectionOptions_Mqtt added in v0.0.49 

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

type ConnectionOptions_Nats added in v0.0.49 

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

type ConnectionOptions_NatsStreaming added in v0.0.49 

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

type ConnectionOptions_Nsq added in v0.0.49 

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

type ConnectionOptions_Postgres added in v0.0.49 

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

type ConnectionOptions_Pulsar added in v0.0.49 

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

type ConnectionOptions_Rabbit added in v0.0.49 

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

type ConnectionOptions_RabbitStreams added in v0.0.49 

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

type ConnectionOptions_RedisPubsub added in v0.0.49 

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

type ConnectionOptions_RedisStreams added in v0.0.49 

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

type ConvertOption added in v0.0.49 

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

func (ConvertOption) EnumDescriptor added in v0.0.49 

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

func (ConvertOption) String added in v0.0.49 

func (x ConvertOption) String() string

type Counter added in v0.0.92 

type Counter struct {
	Resource             Counter_Resource `protobuf:"varint,1,opt,name=resource,proto3,enum=protos.opts.Counter_Resource" json:"resource,omitempty"`
	Type                 Counter_Type     `protobuf:"varint,2,opt,name=type,proto3,enum=protos.opts.Counter_Type" json:"type,omitempty"`
	Name                 string           `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ResourceId           string           `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Value                float64          `protobuf:"fixed64,5,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Counter) Descriptor added in v0.0.92 

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

func (*Counter) GetName added in v0.0.92 

func (m *Counter) GetName() string

func (*Counter) GetResource added in v0.0.92 

func (m *Counter) GetResource() Counter_Resource

func (*Counter) GetResourceId added in v0.0.92 

func (m *Counter) GetResourceId() string

func (*Counter) GetType added in v0.0.92 

func (m *Counter) GetType() Counter_Type

func (*Counter) GetValue added in v0.0.92 

func (m *Counter) GetValue() float64

func (*Counter) ProtoMessage added in v0.0.92 

func (*Counter) ProtoMessage()

func (*Counter) Reset added in v0.0.92 

func (m *Counter) Reset()

func (*Counter) String added in v0.0.92 

func (m *Counter) String() string

func (*Counter) XXX_DiscardUnknown added in v0.0.92 

func (m *Counter) XXX_DiscardUnknown()

func (*Counter) XXX_Marshal added in v0.0.92 

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

func (*Counter) XXX_Merge added in v0.0.92 

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

func (*Counter) XXX_Size added in v0.0.92 

func (m *Counter) XXX_Size() int

func (*Counter) XXX_Unmarshal added in v0.0.92 

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

type Counter_Resource added in v0.0.92 

type Counter_Resource int32
const (
	Counter_RESOURCE_UNSET      Counter_Resource = 0
	Counter_RESOURCE_CONNECTION Counter_Resource = 1
	Counter_RESOURCE_READ       Counter_Resource = 2
	Counter_RESOURCE_SCHEMA     Counter_Resource = 3
	Counter_RESOURCE_REPLAY     Counter_Resource = 4
)

func (Counter_Resource) EnumDescriptor added in v0.0.92 

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

func (Counter_Resource) String added in v0.0.92 

func (x Counter_Resource) String() string

type Counter_Type added in v0.0.92 

type Counter_Type int32
const (
	Counter_TYPE_UNSET            Counter_Type = 0
	Counter_TYPE_SCHEMA_VIOLATION Counter_Type = 1
	Counter_TYPE_MESSAGE_RECEIVED Counter_Type = 2
	Counter_TYPE_MESSAGE_REPLAYED Counter_Type = 3
)

func (Counter_Type) EnumDescriptor added in v0.0.92 

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

func (Counter_Type) String added in v0.0.92 

func (x Counter_Type) String() string

type DynamicGroupAWSSNSOptions added in v0.0.54 

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

func (*DynamicGroupAWSSNSOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupAWSSNSOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupAWSSNSOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupAWSSNSOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupAWSSNSOptions) ProtoMessage()

func (*DynamicGroupAWSSNSOptions) Reset added in v0.0.54 

func (m *DynamicGroupAWSSNSOptions) Reset()

func (*DynamicGroupAWSSNSOptions) String added in v0.0.54 

func (m *DynamicGroupAWSSNSOptions) String() string

func (*DynamicGroupAWSSNSOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupAWSSNSOptions) XXX_DiscardUnknown()

func (*DynamicGroupAWSSNSOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupAWSSNSOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupAWSSNSOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupAWSSNSOptions) XXX_Size() int

func (*DynamicGroupAWSSNSOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupAWSSQSOptions added in v0.0.54 

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

func (*DynamicGroupAWSSQSOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupAWSSQSOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupAWSSQSOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupAWSSQSOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupAWSSQSOptions) ProtoMessage()

func (*DynamicGroupAWSSQSOptions) Reset added in v0.0.54 

func (m *DynamicGroupAWSSQSOptions) Reset()

func (*DynamicGroupAWSSQSOptions) String added in v0.0.54 

func (m *DynamicGroupAWSSQSOptions) String() string

func (*DynamicGroupAWSSQSOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupAWSSQSOptions) XXX_DiscardUnknown()

func (*DynamicGroupAWSSQSOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupAWSSQSOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupAWSSQSOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupAWSSQSOptions) XXX_Size() int

func (*DynamicGroupAWSSQSOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupActiveMQOptions added in v0.0.54 

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

func (*DynamicGroupActiveMQOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupActiveMQOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupActiveMQOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupActiveMQOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupActiveMQOptions) ProtoMessage()

func (*DynamicGroupActiveMQOptions) Reset added in v0.0.54 

func (m *DynamicGroupActiveMQOptions) Reset()

func (*DynamicGroupActiveMQOptions) String added in v0.0.54 

func (m *DynamicGroupActiveMQOptions) String() string

func (*DynamicGroupActiveMQOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupActiveMQOptions) XXX_DiscardUnknown()

func (*DynamicGroupActiveMQOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupActiveMQOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupActiveMQOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupActiveMQOptions) XXX_Size() int

func (*DynamicGroupActiveMQOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupAzureEventHubOptions added in v0.0.54 

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

func (*DynamicGroupAzureEventHubOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupAzureEventHubOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupAzureEventHubOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupAzureEventHubOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupAzureEventHubOptions) ProtoMessage()

func (*DynamicGroupAzureEventHubOptions) Reset added in v0.0.54 

func (m *DynamicGroupAzureEventHubOptions) Reset()

func (*DynamicGroupAzureEventHubOptions) String added in v0.0.54 

func (m *DynamicGroupAzureEventHubOptions) String() string

func (*DynamicGroupAzureEventHubOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupAzureEventHubOptions) XXX_DiscardUnknown()

func (*DynamicGroupAzureEventHubOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupAzureEventHubOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupAzureEventHubOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupAzureEventHubOptions) XXX_Size() int

func (*DynamicGroupAzureEventHubOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupAzureServiceBusOptions added in v0.0.54 

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

func (*DynamicGroupAzureServiceBusOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupAzureServiceBusOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupAzureServiceBusOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupAzureServiceBusOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupAzureServiceBusOptions) ProtoMessage()

func (*DynamicGroupAzureServiceBusOptions) Reset added in v0.0.54 

func (m *DynamicGroupAzureServiceBusOptions) Reset()

func (*DynamicGroupAzureServiceBusOptions) String added in v0.0.54 

func (m *DynamicGroupAzureServiceBusOptions) String() string

func (*DynamicGroupAzureServiceBusOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupAzureServiceBusOptions) XXX_DiscardUnknown()

func (*DynamicGroupAzureServiceBusOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupAzureServiceBusOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupAzureServiceBusOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupAzureServiceBusOptions) XXX_Size() int

func (*DynamicGroupAzureServiceBusOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupGCPPubSubOptions added in v0.0.54 

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

func (*DynamicGroupGCPPubSubOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupGCPPubSubOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupGCPPubSubOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupGCPPubSubOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupGCPPubSubOptions) ProtoMessage()

func (*DynamicGroupGCPPubSubOptions) Reset added in v0.0.54 

func (m *DynamicGroupGCPPubSubOptions) Reset()

func (*DynamicGroupGCPPubSubOptions) String added in v0.0.54 

func (m *DynamicGroupGCPPubSubOptions) String() string

func (*DynamicGroupGCPPubSubOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupGCPPubSubOptions) XXX_DiscardUnknown()

func (*DynamicGroupGCPPubSubOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupGCPPubSubOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupGCPPubSubOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupGCPPubSubOptions) XXX_Size() int

func (*DynamicGroupGCPPubSubOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupKafkaOptions added in v0.0.54 

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

func (*DynamicGroupKafkaOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupKafkaOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupKafkaOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupKafkaOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupKafkaOptions) ProtoMessage()

func (*DynamicGroupKafkaOptions) Reset added in v0.0.54 

func (m *DynamicGroupKafkaOptions) Reset()

func (*DynamicGroupKafkaOptions) String added in v0.0.54 

func (m *DynamicGroupKafkaOptions) String() string

func (*DynamicGroupKafkaOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupKafkaOptions) XXX_DiscardUnknown()

func (*DynamicGroupKafkaOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupKafkaOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupKafkaOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupKafkaOptions) XXX_Size() int

func (*DynamicGroupKafkaOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupKubeMQQueueOptions added in v0.0.54 

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

func (*DynamicGroupKubeMQQueueOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupKubeMQQueueOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupKubeMQQueueOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupKubeMQQueueOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupKubeMQQueueOptions) ProtoMessage()

func (*DynamicGroupKubeMQQueueOptions) Reset added in v0.0.54 

func (m *DynamicGroupKubeMQQueueOptions) Reset()

func (*DynamicGroupKubeMQQueueOptions) String added in v0.0.54 

func (m *DynamicGroupKubeMQQueueOptions) String() string

func (*DynamicGroupKubeMQQueueOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupKubeMQQueueOptions) XXX_DiscardUnknown()

func (*DynamicGroupKubeMQQueueOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupKubeMQQueueOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupKubeMQQueueOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupKubeMQQueueOptions) XXX_Size() int

func (*DynamicGroupKubeMQQueueOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupMQTTOptions added in v0.0.54 

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

func (*DynamicGroupMQTTOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupMQTTOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupMQTTOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupMQTTOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupMQTTOptions) ProtoMessage()

func (*DynamicGroupMQTTOptions) Reset added in v0.0.54 

func (m *DynamicGroupMQTTOptions) Reset()

func (*DynamicGroupMQTTOptions) String added in v0.0.54 

func (m *DynamicGroupMQTTOptions) String() string

func (*DynamicGroupMQTTOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupMQTTOptions) XXX_DiscardUnknown()

func (*DynamicGroupMQTTOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupMQTTOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupMQTTOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupMQTTOptions) XXX_Size() int

func (*DynamicGroupMQTTOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupNSQOptions added in v0.0.54 

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

func (*DynamicGroupNSQOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupNSQOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupNSQOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupNSQOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupNSQOptions) ProtoMessage()

func (*DynamicGroupNSQOptions) Reset added in v0.0.54 

func (m *DynamicGroupNSQOptions) Reset()

func (*DynamicGroupNSQOptions) String added in v0.0.54 

func (m *DynamicGroupNSQOptions) String() string

func (*DynamicGroupNSQOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupNSQOptions) XXX_DiscardUnknown()

func (*DynamicGroupNSQOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupNSQOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupNSQOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupNSQOptions) XXX_Size() int

func (*DynamicGroupNSQOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupNatsOptions added in v0.0.54 

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

func (*DynamicGroupNatsOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupNatsOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupNatsOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupNatsOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupNatsOptions) ProtoMessage()

func (*DynamicGroupNatsOptions) Reset added in v0.0.54 

func (m *DynamicGroupNatsOptions) Reset()

func (*DynamicGroupNatsOptions) String added in v0.0.54 

func (m *DynamicGroupNatsOptions) String() string

func (*DynamicGroupNatsOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupNatsOptions) XXX_DiscardUnknown()

func (*DynamicGroupNatsOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupNatsOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupNatsOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupNatsOptions) XXX_Size() int

func (*DynamicGroupNatsOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupNatsStreamingOptions added in v0.0.54 

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

func (*DynamicGroupNatsStreamingOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupNatsStreamingOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupNatsStreamingOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupNatsStreamingOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupNatsStreamingOptions) ProtoMessage()

func (*DynamicGroupNatsStreamingOptions) Reset added in v0.0.54 

func (m *DynamicGroupNatsStreamingOptions) Reset()

func (*DynamicGroupNatsStreamingOptions) String added in v0.0.54 

func (m *DynamicGroupNatsStreamingOptions) String() string

func (*DynamicGroupNatsStreamingOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupNatsStreamingOptions) XXX_DiscardUnknown()

func (*DynamicGroupNatsStreamingOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupNatsStreamingOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupNatsStreamingOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupNatsStreamingOptions) XXX_Size() int

func (*DynamicGroupNatsStreamingOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupRabbitOptions added in v0.0.54 

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

func (*DynamicGroupRabbitOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupRabbitOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupRabbitOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupRabbitOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupRabbitOptions) ProtoMessage()

func (*DynamicGroupRabbitOptions) Reset added in v0.0.54 

func (m *DynamicGroupRabbitOptions) Reset()

func (*DynamicGroupRabbitOptions) String added in v0.0.54 

func (m *DynamicGroupRabbitOptions) String() string

func (*DynamicGroupRabbitOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupRabbitOptions) XXX_DiscardUnknown()

func (*DynamicGroupRabbitOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupRabbitOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupRabbitOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupRabbitOptions) XXX_Size() int

func (*DynamicGroupRabbitOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupRabbitStreamsOptions added in v0.0.54 

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

func (*DynamicGroupRabbitStreamsOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupRabbitStreamsOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupRabbitStreamsOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupRabbitStreamsOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupRabbitStreamsOptions) ProtoMessage()

func (*DynamicGroupRabbitStreamsOptions) Reset added in v0.0.54 

func (m *DynamicGroupRabbitStreamsOptions) Reset()

func (*DynamicGroupRabbitStreamsOptions) String added in v0.0.54 

func (m *DynamicGroupRabbitStreamsOptions) String() string

func (*DynamicGroupRabbitStreamsOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupRabbitStreamsOptions) XXX_DiscardUnknown()

func (*DynamicGroupRabbitStreamsOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupRabbitStreamsOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupRabbitStreamsOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupRabbitStreamsOptions) XXX_Size() int

func (*DynamicGroupRabbitStreamsOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupRedisPubSubOptions added in v0.0.54 

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

func (*DynamicGroupRedisPubSubOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupRedisPubSubOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupRedisPubSubOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupRedisPubSubOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupRedisPubSubOptions) ProtoMessage()

func (*DynamicGroupRedisPubSubOptions) Reset added in v0.0.54 

func (m *DynamicGroupRedisPubSubOptions) Reset()

func (*DynamicGroupRedisPubSubOptions) String added in v0.0.54 

func (m *DynamicGroupRedisPubSubOptions) String() string

func (*DynamicGroupRedisPubSubOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupRedisPubSubOptions) XXX_DiscardUnknown()

func (*DynamicGroupRedisPubSubOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupRedisPubSubOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupRedisPubSubOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupRedisPubSubOptions) XXX_Size() int

func (*DynamicGroupRedisPubSubOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicGroupRedisStreamsOptions added in v0.0.54 

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

func (*DynamicGroupRedisStreamsOptions) Descriptor added in v0.0.54 

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

func (*DynamicGroupRedisStreamsOptions) GetArgs added in v0.0.54 

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

func (*DynamicGroupRedisStreamsOptions) GetXConn added in v0.0.54 

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

func (*DynamicGroupRedisStreamsOptions) ProtoMessage added in v0.0.54 

func (*DynamicGroupRedisStreamsOptions) ProtoMessage()

func (*DynamicGroupRedisStreamsOptions) Reset added in v0.0.54 

func (m *DynamicGroupRedisStreamsOptions) Reset()

func (*DynamicGroupRedisStreamsOptions) String added in v0.0.54 

func (m *DynamicGroupRedisStreamsOptions) String() string

func (*DynamicGroupRedisStreamsOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicGroupRedisStreamsOptions) XXX_DiscardUnknown()

func (*DynamicGroupRedisStreamsOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicGroupRedisStreamsOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicGroupRedisStreamsOptions) XXX_Size added in v0.0.54 

func (m *DynamicGroupRedisStreamsOptions) XXX_Size() int

func (*DynamicGroupRedisStreamsOptions) XXX_Unmarshal added in v0.0.54 

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

type DynamicOptions added in v0.0.54 

type DynamicOptions struct {
	// @gotags: kong:"help='API token to use for dynamic destination (Create here: https://console.batch.sh/account/security)',required"
	ApiToken string `` /* 206-byte string literal not displayed */
	// @gotags: kong:"help='Dynamic destination collector address',default='dproxy.batch.sh:443'"
	XGrpcAddress string `` /* 178-byte string literal not displayed */
	// @gotags: kong:"help='Dynamic destination collector initial connection timeout',default=5"
	XGrpcTimeoutSeconds uint32 `` /* 201-byte string literal not displayed */
	// @gotags: kong:"help='Use gRPC insecure mode when talking to Batch'"
	XGrpcInsecure bool `` /* 159-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Apache Kafka'"
	Kafka *DynamicGroupKafkaOptions `protobuf:"bytes,100,opt,name=kafka,proto3" json:"kafka,omitempty" kong:"cmd,help='Apache Kafka'"`
	// @gotags: kong:"cmd,help='Apache ActiveMQ'"
	Activemq *DynamicGroupActiveMQOptions `protobuf:"bytes,101,opt,name=activemq,proto3" json:"activemq,omitempty" kong:"cmd,help='Apache ActiveMQ'"`
	// @gotags: kong:"cmd,help='AWS Simple Queue System'"
	Awssqs *DynamicGroupAWSSQSOptions `protobuf:"bytes,102,opt,name=awssqs,proto3" json:"awssqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='AWS Simple Notification System'"
	Awssns *DynamicGroupAWSSNSOptions `protobuf:"bytes,103,opt,name=awssns,proto3" json:"awssns,omitempty" kong:"cmd,help='AWS Simple Notification System'"`
	// @gotags: kong:"cmd,help='NATS'"
	Nats *DynamicGroupNatsOptions `protobuf:"bytes,104,opt,name=nats,proto3" json:"nats,omitempty" kong:"cmd,help='NATS'"`
	// @gotags: kong:"cmd,help='NATS Streaming'"
	NatsStreaming *DynamicGroupNatsStreamingOptions `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *DynamicGroupNSQOptions `protobuf:"bytes,106,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='RabbitMQ'"
	Rabbit *DynamicGroupRabbitOptions `protobuf:"bytes,107,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='RabbitMQ'"`
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *DynamicGroupMQTTOptions `protobuf:"bytes,108,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *DynamicGroupAzureServiceBusOptions `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Azure Event Hub'"
	AzureEventHub *DynamicGroupAzureEventHubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Google Cloud Platform Pub/Sub'"
	GcpPubsub *DynamicGroupGCPPubSubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *DynamicGroupKubeMQQueueOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *DynamicGroupRedisPubSubOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams         *DynamicGroupRedisStreamsOptions `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*DynamicOptions) Descriptor added in v0.0.54 

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

func (*DynamicOptions) GetActivemq added in v0.0.54 

func (m *DynamicOptions) GetActivemq() *DynamicGroupActiveMQOptions

func (*DynamicOptions) GetApiToken added in v0.0.54 

func (m *DynamicOptions) GetApiToken() string

func (*DynamicOptions) GetAwssns added in v0.0.54 

func (m *DynamicOptions) GetAwssns() *DynamicGroupAWSSNSOptions

func (*DynamicOptions) GetAwssqs added in v0.0.54 

func (m *DynamicOptions) GetAwssqs() *DynamicGroupAWSSQSOptions

func (*DynamicOptions) GetAzureEventHub added in v0.0.54 

func (m *DynamicOptions) GetAzureEventHub() *DynamicGroupAzureEventHubOptions

func (*DynamicOptions) GetAzureServiceBus added in v0.0.54 

func (m *DynamicOptions) GetAzureServiceBus() *DynamicGroupAzureServiceBusOptions

func (*DynamicOptions) GetGcpPubsub added in v0.0.54 

func (m *DynamicOptions) GetGcpPubsub() *DynamicGroupGCPPubSubOptions

func (*DynamicOptions) GetKafka added in v0.0.54 

func (m *DynamicOptions) GetKafka() *DynamicGroupKafkaOptions

func (*DynamicOptions) GetKubemqQueue added in v0.0.54 

func (m *DynamicOptions) GetKubemqQueue() *DynamicGroupKubeMQQueueOptions

func (*DynamicOptions) GetMqtt added in v0.0.54 

func (m *DynamicOptions) GetMqtt() *DynamicGroupMQTTOptions

func (*DynamicOptions) GetNats added in v0.0.54 

func (m *DynamicOptions) GetNats() *DynamicGroupNatsOptions

func (*DynamicOptions) GetNatsStreaming added in v0.0.54 

func (m *DynamicOptions) GetNatsStreaming() *DynamicGroupNatsStreamingOptions

func (*DynamicOptions) GetNsq added in v0.0.54 

func (m *DynamicOptions) GetNsq() *DynamicGroupNSQOptions

func (*DynamicOptions) GetRabbit added in v0.0.54 

func (m *DynamicOptions) GetRabbit() *DynamicGroupRabbitOptions

func (*DynamicOptions) GetRedisPubsub added in v0.0.54 

func (m *DynamicOptions) GetRedisPubsub() *DynamicGroupRedisPubSubOptions

func (*DynamicOptions) GetRedisStreams added in v0.0.54 

func (m *DynamicOptions) GetRedisStreams() *DynamicGroupRedisStreamsOptions

func (*DynamicOptions) GetXGrpcAddress added in v0.0.54 

func (m *DynamicOptions) GetXGrpcAddress() string

func (*DynamicOptions) GetXGrpcInsecure added in v0.0.54 

func (m *DynamicOptions) GetXGrpcInsecure() bool

func (*DynamicOptions) GetXGrpcTimeoutSeconds added in v0.0.54 

func (m *DynamicOptions) GetXGrpcTimeoutSeconds() uint32

func (*DynamicOptions) ProtoMessage added in v0.0.54 

func (*DynamicOptions) ProtoMessage()

func (*DynamicOptions) Reset added in v0.0.54 

func (m *DynamicOptions) Reset()

func (*DynamicOptions) String added in v0.0.54 

func (m *DynamicOptions) String() string

func (*DynamicOptions) XXX_DiscardUnknown added in v0.0.54 

func (m *DynamicOptions) XXX_DiscardUnknown()

func (*DynamicOptions) XXX_Marshal added in v0.0.54 

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

func (*DynamicOptions) XXX_Merge added in v0.0.54 

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

func (*DynamicOptions) XXX_Size added in v0.0.54 

func (m *DynamicOptions) XXX_Size() int

func (*DynamicOptions) XXX_Unmarshal added in v0.0.54 

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

type GlobalCLIOptions added in v0.0.51 

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

func (*GlobalCLIOptions) Descriptor added in v0.0.51 

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

func (*GlobalCLIOptions) GetDebug added in v0.0.51 

func (m *GlobalCLIOptions) GetDebug() bool

func (*GlobalCLIOptions) GetQuiet added in v0.0.51 

func (m *GlobalCLIOptions) GetQuiet() bool

func (*GlobalCLIOptions) GetVersion added in v0.0.51 

func (m *GlobalCLIOptions) GetVersion() bool

func (*GlobalCLIOptions) GetXAction added in v0.0.51 

func (m *GlobalCLIOptions) GetXAction() string

func (*GlobalCLIOptions) GetXBackend added in v0.0.51 

func (m *GlobalCLIOptions) GetXBackend() string

func (*GlobalCLIOptions) GetXFullCommand added in v0.0.51 

func (m *GlobalCLIOptions) GetXFullCommand() string

func (*GlobalCLIOptions) ProtoMessage added in v0.0.51 

func (*GlobalCLIOptions) ProtoMessage()

func (*GlobalCLIOptions) Reset added in v0.0.51 

func (m *GlobalCLIOptions) Reset()

func (*GlobalCLIOptions) String added in v0.0.51 

func (m *GlobalCLIOptions) String() string

func (*GlobalCLIOptions) XXX_DiscardUnknown added in v0.0.51 

func (m *GlobalCLIOptions) XXX_DiscardUnknown()

func (*GlobalCLIOptions) XXX_Marshal added in v0.0.51 

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

func (*GlobalCLIOptions) XXX_Merge added in v0.0.51 

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

func (*GlobalCLIOptions) XXX_Size added in v0.0.51 

func (m *GlobalCLIOptions) XXX_Size() int

func (*GlobalCLIOptions) XXX_Unmarshal added in v0.0.51 

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

type 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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*HTTPDestination) Descriptor added in v0.0.54 

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

func (*HTTPDestination) GetHeaders added in v0.0.54 

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

func (*HTTPDestination) GetUrl added in v0.0.54 

func (m *HTTPDestination) GetUrl() string

func (*HTTPDestination) ProtoMessage added in v0.0.54 

func (*HTTPDestination) ProtoMessage()

func (*HTTPDestination) Reset added in v0.0.54 

func (m *HTTPDestination) Reset()

func (*HTTPDestination) String added in v0.0.54 

func (m *HTTPDestination) String() string

func (*HTTPDestination) XXX_DiscardUnknown added in v0.0.54 

func (m *HTTPDestination) XXX_DiscardUnknown()

func (*HTTPDestination) XXX_Marshal added in v0.0.54 

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

func (*HTTPDestination) XXX_Merge added in v0.0.54 

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

func (*HTTPDestination) XXX_Size added in v0.0.54 

func (m *HTTPDestination) XXX_Size() int

func (*HTTPDestination) XXX_Unmarshal added in v0.0.54 

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

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:"-"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InferSchemaOptions) Descriptor added in v0.0.82 

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

func (*InferSchemaOptions) GetSchemaId added in v0.0.82 

func (m *InferSchemaOptions) GetSchemaId() string

func (*InferSchemaOptions) GetType added in v0.0.82 

func (m *InferSchemaOptions) GetType() InferSchemaOptions_Type

func (*InferSchemaOptions) ProtoMessage added in v0.0.82 

func (*InferSchemaOptions) ProtoMessage()

func (*InferSchemaOptions) Reset added in v0.0.82 

func (m *InferSchemaOptions) Reset()

func (*InferSchemaOptions) String added in v0.0.82 

func (m *InferSchemaOptions) String() string

func (*InferSchemaOptions) XXX_DiscardUnknown added in v0.0.82 

func (m *InferSchemaOptions) XXX_DiscardUnknown()

func (*InferSchemaOptions) XXX_Marshal added in v0.0.82 

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

func (*InferSchemaOptions) XXX_Merge added in v0.0.82 

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

func (*InferSchemaOptions) XXX_Size added in v0.0.82 

func (m *InferSchemaOptions) XXX_Size() int

func (*InferSchemaOptions) XXX_Unmarshal added in v0.0.82 

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

type InferSchemaOptions_Type added in v0.0.82 

type InferSchemaOptions_Type int32
const (
	InferSchemaOptions_UNSET      InferSchemaOptions_Type = 0
	InferSchemaOptions_JSONSchema InferSchemaOptions_Type = 1
)

func (InferSchemaOptions_Type) EnumDescriptor added in v0.0.82 

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

func (InferSchemaOptions_Type) String added in v0.0.82 

func (x InferSchemaOptions_Type) String() string

type IsAlertOutput_Output added in v0.0.84 

type IsAlertOutput_Output = isAlertOutput_Output

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 IsMonitorOptions_Config added in v0.0.84 

type IsMonitorOptions_Config = isMonitorOptions_Config

type MonitorOptions added in v0.0.84 

type MonitorOptions struct {
	XId             string `protobuf:"bytes,1,opt,name=_id,json=Id,proto3" json:"_id,omitempty"`
	XCreatedBy      string `protobuf:"bytes,2,opt,name=_created_by,json=CreatedBy,proto3" json:"_created_by,omitempty"`
	XCreatedAtTsUtc int64  `protobuf:"varint,3,opt,name=_created_at_ts_utc,json=CreatedAtTsUtc,proto3" json:"_created_at_ts_utc,omitempty"`
	Notes           string `protobuf:"bytes,4,opt,name=notes,proto3" json:"notes,omitempty"`
	// Types that are valid to be assigned to Config:
	//	*MonitorOptions_SchemaValidation
	//	*MonitorOptions_ServiceSchemaVersion
	//	*MonitorOptions_ReadHasData
	Config               isMonitorOptions_Config `protobuf_oneof:"config"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*MonitorOptions) Descriptor added in v0.0.84 

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

func (*MonitorOptions) GetConfig added in v0.0.84 

func (m *MonitorOptions) GetConfig() isMonitorOptions_Config

func (*MonitorOptions) GetNotes added in v0.0.84 

func (m *MonitorOptions) GetNotes() string

func (*MonitorOptions) GetReadHasData added in v0.0.84 

func (m *MonitorOptions) GetReadHasData() *MonitorReadHasDataConfig

func (*MonitorOptions) GetSchemaValidation added in v0.0.84 

func (m *MonitorOptions) GetSchemaValidation() *MonitorSchemaValidationConfig

func (*MonitorOptions) GetServiceSchemaVersion added in v0.0.84 

func (m *MonitorOptions) GetServiceSchemaVersion() *MonitorServiceSchemaVersionConfig

func (*MonitorOptions) GetXCreatedAtTsUtc added in v0.0.84 

func (m *MonitorOptions) GetXCreatedAtTsUtc() int64

func (*MonitorOptions) GetXCreatedBy added in v0.0.84 

func (m *MonitorOptions) GetXCreatedBy() string

func (*MonitorOptions) GetXId added in v0.0.84 

func (m *MonitorOptions) GetXId() string

func (*MonitorOptions) ProtoMessage added in v0.0.84 

func (*MonitorOptions) ProtoMessage()

func (*MonitorOptions) Reset added in v0.0.84 

func (m *MonitorOptions) Reset()

func (*MonitorOptions) String added in v0.0.84 

func (m *MonitorOptions) String() string

func (*MonitorOptions) XXX_DiscardUnknown added in v0.0.84 

func (m *MonitorOptions) XXX_DiscardUnknown()

func (*MonitorOptions) XXX_Marshal added in v0.0.84 

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

func (*MonitorOptions) XXX_Merge added in v0.0.84 

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

func (*MonitorOptions) XXX_OneofWrappers added in v0.0.84 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*MonitorOptions) XXX_Size added in v0.0.84 

func (m *MonitorOptions) XXX_Size() int

func (*MonitorOptions) XXX_Unmarshal added in v0.0.84 

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

type MonitorOptions_ReadHasData added in v0.0.84 

type MonitorOptions_ReadHasData struct {
	ReadHasData *MonitorReadHasDataConfig `protobuf:"bytes,102,opt,name=read_has_data,json=readHasData,proto3,oneof"`
}

type MonitorOptions_SchemaValidation added in v0.0.84 

type MonitorOptions_SchemaValidation struct {
	SchemaValidation *MonitorSchemaValidationConfig `protobuf:"bytes,100,opt,name=schema_validation,json=schemaValidation,proto3,oneof"`
}

type MonitorOptions_ServiceSchemaVersion added in v0.0.84 

type MonitorOptions_ServiceSchemaVersion struct {
	ServiceSchemaVersion *MonitorServiceSchemaVersionConfig `protobuf:"bytes,101,opt,name=service_schema_version,json=serviceSchemaVersion,proto3,oneof"`
}

type MonitorReadHasDataConfig added in v0.0.84 

type MonitorReadHasDataConfig struct {
	// Which reads does this alert config pertain to?
	ReadIds              []string     `protobuf:"bytes,1,rep,name=read_ids,json=readIds,proto3" json:"read_ids,omitempty"`
	Operator             ReadOperator `protobuf:"varint,2,opt,name=operator,proto3,enum=protos.opts.ReadOperator" json:"operator,omitempty"`
	Value                int32        `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`
	IntervalSeconds      int32        `protobuf:"varint,4,opt,name=interval_seconds,json=intervalSeconds,proto3" json:"interval_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*MonitorReadHasDataConfig) Descriptor added in v0.0.84 

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

func (*MonitorReadHasDataConfig) GetIntervalSeconds added in v0.0.84 

func (m *MonitorReadHasDataConfig) GetIntervalSeconds() int32

func (*MonitorReadHasDataConfig) GetOperator added in v0.0.84 

func (m *MonitorReadHasDataConfig) GetOperator() ReadOperator

func (*MonitorReadHasDataConfig) GetReadIds added in v0.0.84 

func (m *MonitorReadHasDataConfig) GetReadIds() []string

func (*MonitorReadHasDataConfig) GetValue added in v0.0.84 

func (m *MonitorReadHasDataConfig) GetValue() int32

func (*MonitorReadHasDataConfig) ProtoMessage added in v0.0.84 

func (*MonitorReadHasDataConfig) ProtoMessage()

func (*MonitorReadHasDataConfig) Reset added in v0.0.84 

func (m *MonitorReadHasDataConfig) Reset()

func (*MonitorReadHasDataConfig) String added in v0.0.84 

func (m *MonitorReadHasDataConfig) String() string

func (*MonitorReadHasDataConfig) XXX_DiscardUnknown added in v0.0.84 

func (m *MonitorReadHasDataConfig) XXX_DiscardUnknown()

func (*MonitorReadHasDataConfig) XXX_Marshal added in v0.0.84 

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

func (*MonitorReadHasDataConfig) XXX_Merge added in v0.0.84 

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

func (*MonitorReadHasDataConfig) XXX_Size added in v0.0.84 

func (m *MonitorReadHasDataConfig) XXX_Size() int

func (*MonitorReadHasDataConfig) XXX_Unmarshal added in v0.0.84 

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

type MonitorSchemaValidationConfig added in v0.0.84 

type MonitorSchemaValidationConfig struct {
	// SchemaID is the read's schema
	SchemaId []string `protobuf:"bytes,1,rep,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	// Array of validations to perform on the payload
	Validations          []*common.Validation `protobuf:"bytes,2,rep,name=validations,proto3" json:"validations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*MonitorSchemaValidationConfig) Descriptor added in v0.0.84 

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

func (*MonitorSchemaValidationConfig) GetSchemaId added in v0.0.84 

func (m *MonitorSchemaValidationConfig) GetSchemaId() []string

func (*MonitorSchemaValidationConfig) GetValidations added in v0.0.88 

func (m *MonitorSchemaValidationConfig) GetValidations() []*common.Validation

func (*MonitorSchemaValidationConfig) ProtoMessage added in v0.0.84 

func (*MonitorSchemaValidationConfig) ProtoMessage()

func (*MonitorSchemaValidationConfig) Reset added in v0.0.84 

func (m *MonitorSchemaValidationConfig) Reset()

func (*MonitorSchemaValidationConfig) String added in v0.0.84 

func (m *MonitorSchemaValidationConfig) String() string

func (*MonitorSchemaValidationConfig) XXX_DiscardUnknown added in v0.0.84 

func (m *MonitorSchemaValidationConfig) XXX_DiscardUnknown()

func (*MonitorSchemaValidationConfig) XXX_Marshal added in v0.0.84 

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

func (*MonitorSchemaValidationConfig) XXX_Merge added in v0.0.84 

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

func (*MonitorSchemaValidationConfig) XXX_Size added in v0.0.84 

func (m *MonitorSchemaValidationConfig) XXX_Size() int

func (*MonitorSchemaValidationConfig) XXX_Unmarshal added in v0.0.84 

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

type MonitorServiceSchemaVersionConfig added in v0.0.84 

type MonitorServiceSchemaVersionConfig struct {
	ServiceId string                          `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Type      MonitorServiceSchemaVersionType `protobuf:"varint,2,opt,name=type,proto3,enum=protos.opts.MonitorServiceSchemaVersionType" json:"type,omitempty"`
	// Potentially set, depending on condition
	Args                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*MonitorServiceSchemaVersionConfig) Descriptor added in v0.0.84 

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

func (*MonitorServiceSchemaVersionConfig) GetArgs added in v0.0.84 

func (m *MonitorServiceSchemaVersionConfig) GetArgs() map[string]string

func (*MonitorServiceSchemaVersionConfig) GetServiceId added in v0.0.91 

func (m *MonitorServiceSchemaVersionConfig) GetServiceId() string

func (*MonitorServiceSchemaVersionConfig) GetType added in v0.0.84 

func (m *MonitorServiceSchemaVersionConfig) GetType() MonitorServiceSchemaVersionType

func (*MonitorServiceSchemaVersionConfig) ProtoMessage added in v0.0.84 

func (*MonitorServiceSchemaVersionConfig) ProtoMessage()

func (*MonitorServiceSchemaVersionConfig) Reset added in v0.0.84 

func (m *MonitorServiceSchemaVersionConfig) Reset()

func (*MonitorServiceSchemaVersionConfig) String added in v0.0.84 

func (m *MonitorServiceSchemaVersionConfig) String() string

func (*MonitorServiceSchemaVersionConfig) XXX_DiscardUnknown added in v0.0.84 

func (m *MonitorServiceSchemaVersionConfig) XXX_DiscardUnknown()

func (*MonitorServiceSchemaVersionConfig) XXX_Marshal added in v0.0.84 

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

func (*MonitorServiceSchemaVersionConfig) XXX_Merge added in v0.0.84 

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

func (*MonitorServiceSchemaVersionConfig) XXX_Size added in v0.0.84 

func (m *MonitorServiceSchemaVersionConfig) XXX_Size() int

func (*MonitorServiceSchemaVersionConfig) XXX_Unmarshal added in v0.0.84 

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

type MonitorServiceSchemaVersionType added in v0.0.84 

type MonitorServiceSchemaVersionType int32
const (
	// Default to "latest" check
	MonitorServiceSchemaVersionType_SERVICE_SCHEMA_VERSION_CONDITION_TYPE_LATEST MonitorServiceSchemaVersionType = 0
	// If this is used, consumer knows that they should look into
	// condition_args["version"]
	MonitorServiceSchemaVersionType_SERVICE_SCHEMA_VERSION_CONDITION_TYPE_EXACT MonitorServiceSchemaVersionType = 1
)

func (MonitorServiceSchemaVersionType) EnumDescriptor added in v0.0.84 

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

func (MonitorServiceSchemaVersionType) String added in v0.0.84 

func (x MonitorServiceSchemaVersionType) 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:"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='Provide pretty output'"
	Pretty               bool     `protobuf:"varint,4,opt,name=pretty,proto3" json:"pretty,omitempty" kong:"help='Provide pretty output'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadCLIOptions) Descriptor added in v0.0.49 

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

func (*ReadCLIOptions) GetPretty added in v0.0.54 

func (m *ReadCLIOptions) GetPretty() bool

func (*ReadCLIOptions) GetStatsEnable added in v0.0.49 

func (m *ReadCLIOptions) GetStatsEnable() bool

func (*ReadCLIOptions) GetStatsReportIntervalSec added in v0.0.49 

func (m *ReadCLIOptions) GetStatsReportIntervalSec() int32

func (*ReadCLIOptions) GetVerboseOutput added in v0.0.49 

func (m *ReadCLIOptions) GetVerboseOutput() bool

func (*ReadCLIOptions) ProtoMessage added in v0.0.49 

func (*ReadCLIOptions) ProtoMessage()

func (*ReadCLIOptions) Reset added in v0.0.49 

func (m *ReadCLIOptions) Reset()

func (*ReadCLIOptions) String added in v0.0.49 

func (m *ReadCLIOptions) String() string

func (*ReadCLIOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadCLIOptions) XXX_DiscardUnknown()

func (*ReadCLIOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadCLIOptions) XXX_Merge added in v0.0.49 

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

func (*ReadCLIOptions) XXX_Size added in v0.0.49 

func (m *ReadCLIOptions) XXX_Size() int

func (*ReadCLIOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadFilterOptions added in v0.0.75 

type ReadFilterOptions struct {
	// @gotags: kong:"-"
	Query                string   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty" kong:"-"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadFilterOptions) Descriptor added in v0.0.75 

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

func (*ReadFilterOptions) GetQuery added in v0.0.75 

func (m *ReadFilterOptions) GetQuery() string

func (*ReadFilterOptions) ProtoMessage added in v0.0.75 

func (*ReadFilterOptions) ProtoMessage()

func (*ReadFilterOptions) Reset added in v0.0.75 

func (m *ReadFilterOptions) Reset()

func (*ReadFilterOptions) String added in v0.0.75 

func (m *ReadFilterOptions) String() string

func (*ReadFilterOptions) XXX_DiscardUnknown added in v0.0.75 

func (m *ReadFilterOptions) XXX_DiscardUnknown()

func (*ReadFilterOptions) XXX_Marshal added in v0.0.75 

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

func (*ReadFilterOptions) XXX_Merge added in v0.0.75 

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

func (*ReadFilterOptions) XXX_Size added in v0.0.75 

func (m *ReadFilterOptions) XXX_Size() int

func (*ReadFilterOptions) XXX_Unmarshal added in v0.0.75 

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

type ReadGroupAWSSQSOptions added in v0.0.49 

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

func (*ReadGroupAWSSQSOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupAWSSQSOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupAWSSQSOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupAWSSQSOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupAWSSQSOptions) ProtoMessage()

func (*ReadGroupAWSSQSOptions) Reset added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) Reset()

func (*ReadGroupAWSSQSOptions) String added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) String() string

func (*ReadGroupAWSSQSOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) XXX_DiscardUnknown()

func (*ReadGroupAWSSQSOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupAWSSQSOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupAWSSQSOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupAWSSQSOptions) XXX_Size() int

func (*ReadGroupAWSSQSOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupActiveMQOptions added in v0.0.49 

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

func (*ReadGroupActiveMQOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupActiveMQOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupActiveMQOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupActiveMQOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupActiveMQOptions) ProtoMessage()

func (*ReadGroupActiveMQOptions) Reset added in v0.0.49 

func (m *ReadGroupActiveMQOptions) Reset()

func (*ReadGroupActiveMQOptions) String added in v0.0.49 

func (m *ReadGroupActiveMQOptions) String() string

func (*ReadGroupActiveMQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupActiveMQOptions) XXX_DiscardUnknown()

func (*ReadGroupActiveMQOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupActiveMQOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupActiveMQOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupActiveMQOptions) XXX_Size() int

func (*ReadGroupActiveMQOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupAzureEventHubOptions added in v0.0.49 

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

func (*ReadGroupAzureEventHubOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupAzureEventHubOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupAzureEventHubOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupAzureEventHubOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupAzureEventHubOptions) ProtoMessage()

func (*ReadGroupAzureEventHubOptions) Reset added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) Reset()

func (*ReadGroupAzureEventHubOptions) String added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) String() string

func (*ReadGroupAzureEventHubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) XXX_DiscardUnknown()

func (*ReadGroupAzureEventHubOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupAzureEventHubOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupAzureEventHubOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupAzureEventHubOptions) XXX_Size() int

func (*ReadGroupAzureEventHubOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupAzureServiceBusOptions added in v0.0.49 

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

func (*ReadGroupAzureServiceBusOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupAzureServiceBusOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupAzureServiceBusOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupAzureServiceBusOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupAzureServiceBusOptions) ProtoMessage()

func (*ReadGroupAzureServiceBusOptions) Reset added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) Reset()

func (*ReadGroupAzureServiceBusOptions) String added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) String() string

func (*ReadGroupAzureServiceBusOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) XXX_DiscardUnknown()

func (*ReadGroupAzureServiceBusOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupAzureServiceBusOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupAzureServiceBusOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupAzureServiceBusOptions) XXX_Size() int

func (*ReadGroupAzureServiceBusOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupGCPPubSubOptions added in v0.0.49 

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

func (*ReadGroupGCPPubSubOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupGCPPubSubOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupGCPPubSubOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupGCPPubSubOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupGCPPubSubOptions) ProtoMessage()

func (*ReadGroupGCPPubSubOptions) Reset added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) Reset()

func (*ReadGroupGCPPubSubOptions) String added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) String() string

func (*ReadGroupGCPPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) XXX_DiscardUnknown()

func (*ReadGroupGCPPubSubOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupGCPPubSubOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupGCPPubSubOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupGCPPubSubOptions) XXX_Size() int

func (*ReadGroupGCPPubSubOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupKafkaOptions added in v0.0.49 

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

func (*ReadGroupKafkaOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupKafkaOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupKafkaOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupKafkaOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupKafkaOptions) ProtoMessage()

func (*ReadGroupKafkaOptions) Reset added in v0.0.49 

func (m *ReadGroupKafkaOptions) Reset()

func (*ReadGroupKafkaOptions) String added in v0.0.49 

func (m *ReadGroupKafkaOptions) String() string

func (*ReadGroupKafkaOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupKafkaOptions) XXX_DiscardUnknown()

func (*ReadGroupKafkaOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupKafkaOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupKafkaOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupKafkaOptions) XXX_Size() int

func (*ReadGroupKafkaOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupKubeMQQueueOptions added in v0.0.49 

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

func (*ReadGroupKubeMQQueueOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupKubeMQQueueOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupKubeMQQueueOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupKubeMQQueueOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupKubeMQQueueOptions) ProtoMessage()

func (*ReadGroupKubeMQQueueOptions) Reset added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) Reset()

func (*ReadGroupKubeMQQueueOptions) String added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) String() string

func (*ReadGroupKubeMQQueueOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) XXX_DiscardUnknown()

func (*ReadGroupKubeMQQueueOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupKubeMQQueueOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupKubeMQQueueOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupKubeMQQueueOptions) XXX_Size() int

func (*ReadGroupKubeMQQueueOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupMQTTOptions added in v0.0.49 

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

func (*ReadGroupMQTTOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupMQTTOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupMQTTOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupMQTTOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupMQTTOptions) ProtoMessage()

func (*ReadGroupMQTTOptions) Reset added in v0.0.49 

func (m *ReadGroupMQTTOptions) Reset()

func (*ReadGroupMQTTOptions) String added in v0.0.49 

func (m *ReadGroupMQTTOptions) String() string

func (*ReadGroupMQTTOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupMQTTOptions) XXX_DiscardUnknown()

func (*ReadGroupMQTTOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupMQTTOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupMQTTOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupMQTTOptions) XXX_Size() int

func (*ReadGroupMQTTOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupMongoOptions added in v0.0.49 

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

func (*ReadGroupMongoOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupMongoOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupMongoOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupMongoOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupMongoOptions) ProtoMessage()

func (*ReadGroupMongoOptions) Reset added in v0.0.49 

func (m *ReadGroupMongoOptions) Reset()

func (*ReadGroupMongoOptions) String added in v0.0.49 

func (m *ReadGroupMongoOptions) String() string

func (*ReadGroupMongoOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupMongoOptions) XXX_DiscardUnknown()

func (*ReadGroupMongoOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupMongoOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupMongoOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupMongoOptions) XXX_Size() int

func (*ReadGroupMongoOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupNSQOptions added in v0.0.49 

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

func (*ReadGroupNSQOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupNSQOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupNSQOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupNSQOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupNSQOptions) ProtoMessage()

func (*ReadGroupNSQOptions) Reset added in v0.0.49 

func (m *ReadGroupNSQOptions) Reset()

func (*ReadGroupNSQOptions) String added in v0.0.49 

func (m *ReadGroupNSQOptions) String() string

func (*ReadGroupNSQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupNSQOptions) XXX_DiscardUnknown()

func (*ReadGroupNSQOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupNSQOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupNSQOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupNSQOptions) XXX_Size() int

func (*ReadGroupNSQOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupNatsOptions added in v0.0.49 

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

func (*ReadGroupNatsOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupNatsOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupNatsOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupNatsOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupNatsOptions) ProtoMessage()

func (*ReadGroupNatsOptions) Reset added in v0.0.49 

func (m *ReadGroupNatsOptions) Reset()

func (*ReadGroupNatsOptions) String added in v0.0.49 

func (m *ReadGroupNatsOptions) String() string

func (*ReadGroupNatsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupNatsOptions) XXX_DiscardUnknown()

func (*ReadGroupNatsOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupNatsOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupNatsOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupNatsOptions) XXX_Size() int

func (*ReadGroupNatsOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupNatsStreamingOptions added in v0.0.49 

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

func (*ReadGroupNatsStreamingOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupNatsStreamingOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupNatsStreamingOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupNatsStreamingOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupNatsStreamingOptions) ProtoMessage()

func (*ReadGroupNatsStreamingOptions) Reset added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) Reset()

func (*ReadGroupNatsStreamingOptions) String added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) String() string

func (*ReadGroupNatsStreamingOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) XXX_DiscardUnknown()

func (*ReadGroupNatsStreamingOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupNatsStreamingOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupNatsStreamingOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupNatsStreamingOptions) XXX_Size() int

func (*ReadGroupNatsStreamingOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupPostgresOptions added in v0.0.49 

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

func (*ReadGroupPostgresOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupPostgresOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupPostgresOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupPostgresOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupPostgresOptions) ProtoMessage()

func (*ReadGroupPostgresOptions) Reset added in v0.0.49 

func (m *ReadGroupPostgresOptions) Reset()

func (*ReadGroupPostgresOptions) String added in v0.0.49 

func (m *ReadGroupPostgresOptions) String() string

func (*ReadGroupPostgresOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupPostgresOptions) XXX_DiscardUnknown()

func (*ReadGroupPostgresOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupPostgresOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupPostgresOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupPostgresOptions) XXX_Size() int

func (*ReadGroupPostgresOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupPulsarOptions added in v0.0.49 

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

func (*ReadGroupPulsarOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupPulsarOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupPulsarOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupPulsarOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupPulsarOptions) ProtoMessage()

func (*ReadGroupPulsarOptions) Reset added in v0.0.49 

func (m *ReadGroupPulsarOptions) Reset()

func (*ReadGroupPulsarOptions) String added in v0.0.49 

func (m *ReadGroupPulsarOptions) String() string

func (*ReadGroupPulsarOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupPulsarOptions) XXX_DiscardUnknown()

func (*ReadGroupPulsarOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupPulsarOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupPulsarOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupPulsarOptions) XXX_Size() int

func (*ReadGroupPulsarOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupRabbitOptions added in v0.0.49 

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

func (*ReadGroupRabbitOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupRabbitOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupRabbitOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupRabbitOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRabbitOptions) ProtoMessage()

func (*ReadGroupRabbitOptions) Reset added in v0.0.49 

func (m *ReadGroupRabbitOptions) Reset()

func (*ReadGroupRabbitOptions) String added in v0.0.49 

func (m *ReadGroupRabbitOptions) String() string

func (*ReadGroupRabbitOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupRabbitOptions) XXX_DiscardUnknown()

func (*ReadGroupRabbitOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupRabbitOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupRabbitOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupRabbitOptions) XXX_Size() int

func (*ReadGroupRabbitOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupRabbitStreamsOptions added in v0.0.49 

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

func (*ReadGroupRabbitStreamsOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupRabbitStreamsOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupRabbitStreamsOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupRabbitStreamsOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRabbitStreamsOptions) ProtoMessage()

func (*ReadGroupRabbitStreamsOptions) Reset added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) Reset()

func (*ReadGroupRabbitStreamsOptions) String added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) String() string

func (*ReadGroupRabbitStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) XXX_DiscardUnknown()

func (*ReadGroupRabbitStreamsOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupRabbitStreamsOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupRabbitStreamsOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupRabbitStreamsOptions) XXX_Size() int

func (*ReadGroupRabbitStreamsOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupRedisPubSubOptions added in v0.0.49 

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

func (*ReadGroupRedisPubSubOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupRedisPubSubOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupRedisPubSubOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupRedisPubSubOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRedisPubSubOptions) ProtoMessage()

func (*ReadGroupRedisPubSubOptions) Reset added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) Reset()

func (*ReadGroupRedisPubSubOptions) String added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) String() string

func (*ReadGroupRedisPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) XXX_DiscardUnknown()

func (*ReadGroupRedisPubSubOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupRedisPubSubOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupRedisPubSubOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupRedisPubSubOptions) XXX_Size() int

func (*ReadGroupRedisPubSubOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadGroupRedisStreamsOptions added in v0.0.49 

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

func (*ReadGroupRedisStreamsOptions) Descriptor added in v0.0.49 

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

func (*ReadGroupRedisStreamsOptions) GetArgs added in v0.0.49 

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

func (*ReadGroupRedisStreamsOptions) GetXConn added in v0.0.49 

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

func (*ReadGroupRedisStreamsOptions) ProtoMessage added in v0.0.49 

func (*ReadGroupRedisStreamsOptions) ProtoMessage()

func (*ReadGroupRedisStreamsOptions) Reset added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) Reset()

func (*ReadGroupRedisStreamsOptions) String added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) String() string

func (*ReadGroupRedisStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) XXX_DiscardUnknown()

func (*ReadGroupRedisStreamsOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadGroupRedisStreamsOptions) XXX_Merge added in v0.0.49 

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

func (*ReadGroupRedisStreamsOptions) XXX_Size added in v0.0.49 

func (m *ReadGroupRedisStreamsOptions) XXX_Size() int

func (*ReadGroupRedisStreamsOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadOperator added in v0.0.84 

type ReadOperator int32
const (
	ReadOperator_READ_OPERATOR_UNSET ReadOperator = 0
	ReadOperator_READ_OPERATOR_EQ    ReadOperator = 1
	ReadOperator_READ_OPERATOR_LT    ReadOperator = 2
	ReadOperator_READ_OPERATOR_GT    ReadOperator = 3
	ReadOperator_READ_OPERATOR_LTE   ReadOperator = 4
	ReadOperator_READ_OPERATOR_GTE   ReadOperator = 5
)

func (ReadOperator) EnumDescriptor added in v0.0.84 

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

func (ReadOperator) String added in v0.0.84 

func (x ReadOperator) 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=awssqs,proto3" json:"awssqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='MongoDB'"
	Mongo *ReadGroupMongoOptions `protobuf:"bytes,103,opt,name=mongo,proto3" json:"mongo,omitempty" kong:"cmd,help='MongoDB'"`
	// @gotags: kong:"cmd,help='NATS'"
	Nats *ReadGroupNatsOptions `protobuf:"bytes,104,opt,name=nats,proto3" json:"nats,omitempty" kong:"cmd,help='NATS'"`
	// @gotags: kong:"cmd,help='NATS Streaming'"
	NatsStreaming *ReadGroupNatsStreamingOptions `` /* 135-byte string literal not displayed */
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *ReadGroupNSQOptions `protobuf:"bytes,106,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='Apache Pulsar'"
	Pulsar *ReadGroupPulsarOptions `protobuf:"bytes,107,opt,name=pulsar,proto3" json:"pulsar,omitempty" kong:"cmd,help='Apache Pulsar'"`
	// @gotags: kong:"cmd,help='RabbitMQ'"
	Rabbit *ReadGroupRabbitOptions `protobuf:"bytes,108,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='RabbitMQ'"`
	// @gotags: kong:"cmd,help='RabbitMQ Streams'"
	RabbitStreams *ReadGroupRabbitStreamsOptions `` /* 137-byte string literal not displayed */
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *ReadGroupMQTTOptions `protobuf:"bytes,110,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *ReadGroupAzureServiceBusOptions `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help=”"
	AzureEventHub *ReadGroupAzureEventHubOptions `protobuf:"bytes,112,opt,name=azure_event_hub,json=azureEventHub,proto3" json:"azure_event_hub,omitempty" kong:"cmd,help=''"`
	// @gotags: kong:"cmd,help='Google Cloud Platform Pub/Sub'"
	GcpPubsub *ReadGroupGCPPubSubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *ReadGroupKubeMQQueueOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *ReadGroupRedisPubSubOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams *ReadGroupRedisStreamsOptions `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='PostgreSQL'"
	Postgres             *ReadGroupPostgresOptions `protobuf:"bytes,117,opt,name=postgres,proto3" json:"postgres,omitempty" kong:"cmd,help='PostgreSQL'"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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

func (*ReadOptions) Descriptor added in v0.0.49 

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

func (*ReadOptions) GetActivemq added in v0.0.49 

func (m *ReadOptions) GetActivemq() *ReadGroupActiveMQOptions

func (*ReadOptions) GetAwssqs added in v0.0.49 

func (m *ReadOptions) GetAwssqs() *ReadGroupAWSSQSOptions

func (*ReadOptions) GetAzureEventHub added in v0.0.49 

func (m *ReadOptions) GetAzureEventHub() *ReadGroupAzureEventHubOptions

func (*ReadOptions) GetAzureServiceBus added in v0.0.49 

func (m *ReadOptions) GetAzureServiceBus() *ReadGroupAzureServiceBusOptions

func (*ReadOptions) GetConnectionId added in v0.0.49 

func (m *ReadOptions) GetConnectionId() string

func (*ReadOptions) GetContinuous added in v0.0.49 

func (m *ReadOptions) GetContinuous() bool

func (*ReadOptions) GetConvertOutput added in v0.0.54 

func (m *ReadOptions) GetConvertOutput() ConvertOption

func (*ReadOptions) GetDecodeOptions added in v0.0.49 

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

func (*ReadOptions) GetFilter added in v0.0.75 

func (m *ReadOptions) GetFilter() *ReadFilterOptions

func (*ReadOptions) GetGcpPubsub added in v0.0.49 

func (m *ReadOptions) GetGcpPubsub() *ReadGroupGCPPubSubOptions

func (*ReadOptions) GetInferSchemaOptions added in v0.0.82 

func (m *ReadOptions) GetInferSchemaOptions() *InferSchemaOptions

func (*ReadOptions) GetKafka added in v0.0.49 

func (m *ReadOptions) GetKafka() *ReadGroupKafkaOptions

func (*ReadOptions) GetKubemqQueue added in v0.0.49 

func (m *ReadOptions) GetKubemqQueue() *ReadGroupKubeMQQueueOptions

func (*ReadOptions) GetMongo added in v0.0.49 

func (m *ReadOptions) GetMongo() *ReadGroupMongoOptions

func (*ReadOptions) GetMqtt added in v0.0.49 

func (m *ReadOptions) GetMqtt() *ReadGroupMQTTOptions

func (*ReadOptions) GetName added in v0.0.49 

func (m *ReadOptions) GetName() string

func (*ReadOptions) GetNats added in v0.0.49 

func (m *ReadOptions) GetNats() *ReadGroupNatsOptions

func (*ReadOptions) GetNatsStreaming added in v0.0.49 

func (m *ReadOptions) GetNatsStreaming() *ReadGroupNatsStreamingOptions

func (*ReadOptions) GetNsq added in v0.0.49 

func (m *ReadOptions) GetNsq() *ReadGroupNSQOptions

func (*ReadOptions) GetPostgres added in v0.0.49 

func (m *ReadOptions) GetPostgres() *ReadGroupPostgresOptions

func (*ReadOptions) GetPulsar added in v0.0.49 

func (m *ReadOptions) GetPulsar() *ReadGroupPulsarOptions

func (*ReadOptions) GetRabbit added in v0.0.49 

func (m *ReadOptions) GetRabbit() *ReadGroupRabbitOptions

func (*ReadOptions) GetRabbitStreams added in v0.0.49 

func (m *ReadOptions) GetRabbitStreams() *ReadGroupRabbitStreamsOptions

func (*ReadOptions) GetRedisPubsub added in v0.0.49 

func (m *ReadOptions) GetRedisPubsub() *ReadGroupRedisPubSubOptions

func (*ReadOptions) GetRedisStreams added in v0.0.49 

func (m *ReadOptions) GetRedisStreams() *ReadGroupRedisStreamsOptions

func (*ReadOptions) GetSampleOptions added in v0.0.49 

func (m *ReadOptions) GetSampleOptions() *ReadSampleOptions

func (*ReadOptions) GetXActive added in v0.0.49 

func (m *ReadOptions) GetXActive() bool

func (*ReadOptions) GetXCliOptions added in v0.0.49 

func (m *ReadOptions) GetXCliOptions() *ReadCLIOptions

func (*ReadOptions) GetXId added in v0.0.49 

func (m *ReadOptions) GetXId() string

func (*ReadOptions) ProtoMessage added in v0.0.49 

func (*ReadOptions) ProtoMessage()

func (*ReadOptions) Reset added in v0.0.49 

func (m *ReadOptions) Reset()

func (*ReadOptions) String added in v0.0.49 

func (m *ReadOptions) String() string

func (*ReadOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadOptions) XXX_DiscardUnknown()

func (*ReadOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadOptions) XXX_Merge added in v0.0.49 

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

func (*ReadOptions) XXX_Size added in v0.0.49 

func (m *ReadOptions) XXX_Size() int

func (*ReadOptions) XXX_Unmarshal added in v0.0.49 

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

type ReadSampleOptions added in v0.0.49 

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

func (*ReadSampleOptions) Descriptor added in v0.0.49 

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

func (*ReadSampleOptions) GetSampleIntervalSeconds added in v0.0.49 

func (m *ReadSampleOptions) GetSampleIntervalSeconds() uint32

func (*ReadSampleOptions) GetSampleRate added in v0.0.49 

func (m *ReadSampleOptions) GetSampleRate() uint32

func (*ReadSampleOptions) ProtoMessage added in v0.0.49 

func (*ReadSampleOptions) ProtoMessage()

func (*ReadSampleOptions) Reset added in v0.0.49 

func (m *ReadSampleOptions) Reset()

func (*ReadSampleOptions) String added in v0.0.49 

func (m *ReadSampleOptions) String() string

func (*ReadSampleOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ReadSampleOptions) XXX_DiscardUnknown()

func (*ReadSampleOptions) XXX_Marshal added in v0.0.49 

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

func (*ReadSampleOptions) XXX_Merge added in v0.0.49 

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

func (*ReadSampleOptions) XXX_Size added in v0.0.49 

func (m *ReadSampleOptions) XXX_Size() int

func (*ReadSampleOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayCLIOptions added in v0.0.49 

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

func (*RelayCLIOptions) Descriptor added in v0.0.49 

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

func (*RelayCLIOptions) GetHttpListenAddress added in v0.0.49 

func (m *RelayCLIOptions) GetHttpListenAddress() string

func (*RelayCLIOptions) ProtoMessage added in v0.0.49 

func (*RelayCLIOptions) ProtoMessage()

func (*RelayCLIOptions) Reset added in v0.0.49 

func (m *RelayCLIOptions) Reset()

func (*RelayCLIOptions) String added in v0.0.49 

func (m *RelayCLIOptions) String() string

func (*RelayCLIOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayCLIOptions) XXX_DiscardUnknown()

func (*RelayCLIOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayCLIOptions) XXX_Merge added in v0.0.49 

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

func (*RelayCLIOptions) XXX_Size added in v0.0.49 

func (m *RelayCLIOptions) XXX_Size() int

func (*RelayCLIOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupAWSSQSOptions added in v0.0.49 

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

func (*RelayGroupAWSSQSOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupAWSSQSOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupAWSSQSOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupAWSSQSOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupAWSSQSOptions) ProtoMessage()

func (*RelayGroupAWSSQSOptions) Reset added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) Reset()

func (*RelayGroupAWSSQSOptions) String added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) String() string

func (*RelayGroupAWSSQSOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) XXX_DiscardUnknown()

func (*RelayGroupAWSSQSOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupAWSSQSOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupAWSSQSOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupAWSSQSOptions) XXX_Size() int

func (*RelayGroupAWSSQSOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupAzureServiceBusOptions added in v0.0.49 

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

func (*RelayGroupAzureServiceBusOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupAzureServiceBusOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupAzureServiceBusOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupAzureServiceBusOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupAzureServiceBusOptions) ProtoMessage()

func (*RelayGroupAzureServiceBusOptions) Reset added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) Reset()

func (*RelayGroupAzureServiceBusOptions) String added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) String() string

func (*RelayGroupAzureServiceBusOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) XXX_DiscardUnknown()

func (*RelayGroupAzureServiceBusOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupAzureServiceBusOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupAzureServiceBusOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupAzureServiceBusOptions) XXX_Size() int

func (*RelayGroupAzureServiceBusOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupGCPPubSubOptions added in v0.0.49 

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

func (*RelayGroupGCPPubSubOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupGCPPubSubOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupGCPPubSubOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupGCPPubSubOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupGCPPubSubOptions) ProtoMessage()

func (*RelayGroupGCPPubSubOptions) Reset added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) Reset()

func (*RelayGroupGCPPubSubOptions) String added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) String() string

func (*RelayGroupGCPPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) XXX_DiscardUnknown()

func (*RelayGroupGCPPubSubOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupGCPPubSubOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupGCPPubSubOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupGCPPubSubOptions) XXX_Size() int

func (*RelayGroupGCPPubSubOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupKafkaOptions added in v0.0.49 

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

func (*RelayGroupKafkaOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupKafkaOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupKafkaOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupKafkaOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupKafkaOptions) ProtoMessage()

func (*RelayGroupKafkaOptions) Reset added in v0.0.49 

func (m *RelayGroupKafkaOptions) Reset()

func (*RelayGroupKafkaOptions) String added in v0.0.49 

func (m *RelayGroupKafkaOptions) String() string

func (*RelayGroupKafkaOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupKafkaOptions) XXX_DiscardUnknown()

func (*RelayGroupKafkaOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupKafkaOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupKafkaOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupKafkaOptions) XXX_Size() int

func (*RelayGroupKafkaOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupKubeMQQueueOptions added in v0.0.49 

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

func (*RelayGroupKubeMQQueueOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupKubeMQQueueOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupKubeMQQueueOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupKubeMQQueueOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupKubeMQQueueOptions) ProtoMessage()

func (*RelayGroupKubeMQQueueOptions) Reset added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) Reset()

func (*RelayGroupKubeMQQueueOptions) String added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) String() string

func (*RelayGroupKubeMQQueueOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) XXX_DiscardUnknown()

func (*RelayGroupKubeMQQueueOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupKubeMQQueueOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupKubeMQQueueOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupKubeMQQueueOptions) XXX_Size() int

func (*RelayGroupKubeMQQueueOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupMQTTOptions added in v0.0.49 

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

func (*RelayGroupMQTTOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupMQTTOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupMQTTOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupMQTTOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupMQTTOptions) ProtoMessage()

func (*RelayGroupMQTTOptions) Reset added in v0.0.49 

func (m *RelayGroupMQTTOptions) Reset()

func (*RelayGroupMQTTOptions) String added in v0.0.49 

func (m *RelayGroupMQTTOptions) String() string

func (*RelayGroupMQTTOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupMQTTOptions) XXX_DiscardUnknown()

func (*RelayGroupMQTTOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupMQTTOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupMQTTOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupMQTTOptions) XXX_Size() int

func (*RelayGroupMQTTOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupMongoOptions added in v0.0.49 

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

func (*RelayGroupMongoOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupMongoOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupMongoOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupMongoOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupMongoOptions) ProtoMessage()

func (*RelayGroupMongoOptions) Reset added in v0.0.49 

func (m *RelayGroupMongoOptions) Reset()

func (*RelayGroupMongoOptions) String added in v0.0.49 

func (m *RelayGroupMongoOptions) String() string

func (*RelayGroupMongoOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupMongoOptions) XXX_DiscardUnknown()

func (*RelayGroupMongoOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupMongoOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupMongoOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupMongoOptions) XXX_Size() int

func (*RelayGroupMongoOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupNSQOptions added in v0.0.49 

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

func (*RelayGroupNSQOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupNSQOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupNSQOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupNSQOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupNSQOptions) ProtoMessage()

func (*RelayGroupNSQOptions) Reset added in v0.0.49 

func (m *RelayGroupNSQOptions) Reset()

func (*RelayGroupNSQOptions) String added in v0.0.49 

func (m *RelayGroupNSQOptions) String() string

func (*RelayGroupNSQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupNSQOptions) XXX_DiscardUnknown()

func (*RelayGroupNSQOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupNSQOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupNSQOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupNSQOptions) XXX_Size() int

func (*RelayGroupNSQOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupPostgresOptions added in v0.0.49 

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

func (*RelayGroupPostgresOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupPostgresOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupPostgresOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupPostgresOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupPostgresOptions) ProtoMessage()

func (*RelayGroupPostgresOptions) Reset added in v0.0.49 

func (m *RelayGroupPostgresOptions) Reset()

func (*RelayGroupPostgresOptions) String added in v0.0.49 

func (m *RelayGroupPostgresOptions) String() string

func (*RelayGroupPostgresOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupPostgresOptions) XXX_DiscardUnknown()

func (*RelayGroupPostgresOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupPostgresOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupPostgresOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupPostgresOptions) XXX_Size() int

func (*RelayGroupPostgresOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupRabbitOptions added in v0.0.49 

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

func (*RelayGroupRabbitOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupRabbitOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupRabbitOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupRabbitOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupRabbitOptions) ProtoMessage()

func (*RelayGroupRabbitOptions) Reset added in v0.0.49 

func (m *RelayGroupRabbitOptions) Reset()

func (*RelayGroupRabbitOptions) String added in v0.0.49 

func (m *RelayGroupRabbitOptions) String() string

func (*RelayGroupRabbitOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupRabbitOptions) XXX_DiscardUnknown()

func (*RelayGroupRabbitOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupRabbitOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupRabbitOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupRabbitOptions) XXX_Size() int

func (*RelayGroupRabbitOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupRedisPubSubOptions added in v0.0.49 

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

func (*RelayGroupRedisPubSubOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupRedisPubSubOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupRedisPubSubOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupRedisPubSubOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupRedisPubSubOptions) ProtoMessage()

func (*RelayGroupRedisPubSubOptions) Reset added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) Reset()

func (*RelayGroupRedisPubSubOptions) String added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) String() string

func (*RelayGroupRedisPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) XXX_DiscardUnknown()

func (*RelayGroupRedisPubSubOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupRedisPubSubOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupRedisPubSubOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupRedisPubSubOptions) XXX_Size() int

func (*RelayGroupRedisPubSubOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayGroupRedisStreamsOptions added in v0.0.49 

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

func (*RelayGroupRedisStreamsOptions) Descriptor added in v0.0.49 

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

func (*RelayGroupRedisStreamsOptions) GetArgs added in v0.0.49 

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

func (*RelayGroupRedisStreamsOptions) GetXConn added in v0.0.49 

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

func (*RelayGroupRedisStreamsOptions) ProtoMessage added in v0.0.49 

func (*RelayGroupRedisStreamsOptions) ProtoMessage()

func (*RelayGroupRedisStreamsOptions) Reset added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) Reset()

func (*RelayGroupRedisStreamsOptions) String added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) String() string

func (*RelayGroupRedisStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) XXX_DiscardUnknown()

func (*RelayGroupRedisStreamsOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayGroupRedisStreamsOptions) XXX_Merge added in v0.0.49 

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

func (*RelayGroupRedisStreamsOptions) XXX_Size added in v0.0.49 

func (m *RelayGroupRedisStreamsOptions) XXX_Size() int

func (*RelayGroupRedisStreamsOptions) XXX_Unmarshal added in v0.0.49 

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

type RelayOptions added in v0.0.49 

type RelayOptions struct {
	// @gotags: kong:"help='Secret collection token',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:"name='How many workers to launch per relay',env='PLUMBER_RELAY_NUM_WORKERS',default=10"
	NumWorkers int32 `` /* 186-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.batch.sh:9000'"
	XBatchshGrpcAddress string `` /* 269-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=true"
	XBatchshGrpcDisableTls bool `` /* 254-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"
	XBatchshGrpcTimeoutSeconds int32 `` /* 295-byte string literal not displayed */
	// ID of the created relay entry; populated by plumber.
	// @gotags: kong:"-"
	XRelayId string `protobuf:"bytes,1003,opt,name=_relay_id,json=RelayId,proto3" json:"_relay_id,omitempty" kong:"-"`
	// @gotags: kong:"embed"
	XCliOptions *RelayCLIOptions `protobuf:"bytes,1004,opt,name=_cli_options,json=CliOptions,proto3" json:"_cli_options,omitempty" kong:"embed"`
	// @gotags: kong:"cmd,help='Apache Kafka'"
	Kafka *RelayGroupKafkaOptions `protobuf:"bytes,100,opt,name=kafka,proto3" json:"kafka,omitempty" kong:"cmd,help='Apache Kafka'"`
	// @gotags: kong:"cmd,help='AWS Simple Queue System'"
	Awssqs *RelayGroupAWSSQSOptions `protobuf:"bytes,101,opt,name=awssqs,proto3" json:"awssqs,omitempty" kong:"cmd,help='AWS Simple Queue System'"`
	// @gotags: kong:"cmd,help='MongoDB (CDC)'"
	Mongo *RelayGroupMongoOptions `protobuf:"bytes,102,opt,name=mongo,proto3" json:"mongo,omitempty" kong:"cmd,help='MongoDB (CDC)'"`
	// @gotags: kong:"cmd,help='NSQ'"
	Nsq *RelayGroupNSQOptions `protobuf:"bytes,103,opt,name=nsq,proto3" json:"nsq,omitempty" kong:"cmd,help='NSQ'"`
	// @gotags: kong:"cmd,help='MQTT'"
	Rabbit *RelayGroupRabbitOptions `protobuf:"bytes,104,opt,name=rabbit,proto3" json:"rabbit,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='MQTT'"
	Mqtt *RelayGroupMQTTOptions `protobuf:"bytes,105,opt,name=mqtt,proto3" json:"mqtt,omitempty" kong:"cmd,help='MQTT'"`
	// @gotags: kong:"cmd,help='Azure Service Bus'"
	AzureServiceBus *RelayGroupAzureServiceBusOptions `` /* 146-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Google Cloud Platform Pub/Sub'"
	GcpPubsub *RelayGroupGCPPubSubOptions `` /* 138-byte string literal not displayed */
	// @gotags: kong:"cmd,help='KubeMQ Queue'"
	KubemqQueue *RelayGroupKubeMQQueueOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis PubSub'"
	RedisPubsub *RelayGroupRedisPubSubOptions `` /* 127-byte string literal not displayed */
	// @gotags: kong:"cmd,help='Redis Streams'"
	RedisStreams *RelayGroupRedisStreamsOptions `` /* 131-byte string literal not displayed */
	// @gotags: kong:"cmd,help='PostgreSQL (CDC)'"
	Postgres             *RelayGroupPostgresOptions `protobuf:"bytes,112,opt,name=postgres,proto3" json:"postgres,omitempty" kong:"cmd,help='PostgreSQL (CDC)'"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

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

func (*RelayOptions) Descriptor added in v0.0.49 

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

func (*RelayOptions) GetAwssqs added in v0.0.49 

func (m *RelayOptions) GetAwssqs() *RelayGroupAWSSQSOptions

func (*RelayOptions) GetAzureServiceBus added in v0.0.49 

func (m *RelayOptions) GetAzureServiceBus() *RelayGroupAzureServiceBusOptions

func (*RelayOptions) GetBatchMaxRetry added in v0.0.49 

func (m *RelayOptions) GetBatchMaxRetry() int32

func (*RelayOptions) GetBatchSize added in v0.0.49 

func (m *RelayOptions) GetBatchSize() int32

func (*RelayOptions) GetCollectionToken added in v0.0.49 

func (m *RelayOptions) GetCollectionToken() string

func (*RelayOptions) GetConnectionId added in v0.0.49 

func (m *RelayOptions) GetConnectionId() string

func (*RelayOptions) GetGcpPubsub added in v0.0.49 

func (m *RelayOptions) GetGcpPubsub() *RelayGroupGCPPubSubOptions

func (*RelayOptions) GetKafka added in v0.0.49 

func (m *RelayOptions) GetKafka() *RelayGroupKafkaOptions

func (*RelayOptions) GetKubemqQueue added in v0.0.49 

func (m *RelayOptions) GetKubemqQueue() *RelayGroupKubeMQQueueOptions

func (*RelayOptions) GetMongo added in v0.0.49 

func (m *RelayOptions) GetMongo() *RelayGroupMongoOptions

func (*RelayOptions) GetMqtt added in v0.0.49 

func (m *RelayOptions) GetMqtt() *RelayGroupMQTTOptions

func (*RelayOptions) GetNsq added in v0.0.49 

func (m *RelayOptions) GetNsq() *RelayGroupNSQOptions

func (*RelayOptions) GetNumWorkers added in v0.0.49 

func (m *RelayOptions) GetNumWorkers() int32

func (*RelayOptions) GetPostgres added in v0.0.49 

func (m *RelayOptions) GetPostgres() *RelayGroupPostgresOptions

func (*RelayOptions) GetRabbit added in v0.0.49 

func (m *RelayOptions) GetRabbit() *RelayGroupRabbitOptions

func (*RelayOptions) GetRedisPubsub added in v0.0.49 

func (m *RelayOptions) GetRedisPubsub() *RelayGroupRedisPubSubOptions

func (*RelayOptions) GetRedisStreams added in v0.0.49 

func (m *RelayOptions) GetRedisStreams() *RelayGroupRedisStreamsOptions

func (*RelayOptions) GetXBatchshGrpcAddress added in v0.0.49 

func (m *RelayOptions) GetXBatchshGrpcAddress() string

func (*RelayOptions) GetXBatchshGrpcDisableTls added in v0.0.49 

func (m *RelayOptions) GetXBatchshGrpcDisableTls() bool

func (*RelayOptions) GetXBatchshGrpcTimeoutSeconds added in v0.0.49 

func (m *RelayOptions) GetXBatchshGrpcTimeoutSeconds() int32

func (*RelayOptions) GetXCliOptions added in v0.0.49 

func (m *RelayOptions) GetXCliOptions() *RelayCLIOptions

func (*RelayOptions) GetXRelayId added in v0.0.49 

func (m *RelayOptions) GetXRelayId() string

func (*RelayOptions) ProtoMessage added in v0.0.49 

func (*RelayOptions) ProtoMessage()

func (*RelayOptions) Reset added in v0.0.49 

func (m *RelayOptions) Reset()

func (*RelayOptions) String added in v0.0.49 

func (m *RelayOptions) String() string

func (*RelayOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *RelayOptions) XXX_DiscardUnknown()

func (*RelayOptions) XXX_Marshal added in v0.0.49 

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

func (*RelayOptions) XXX_Merge added in v0.0.49 

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

func (*RelayOptions) XXX_Size added in v0.0.49 

func (m *RelayOptions) XXX_Size() int

func (*RelayOptions) XXX_Unmarshal added in v0.0.49 

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

type ServerOptions added in v0.0.49 

type ServerOptions struct {
	// @gotags: kong:"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=127.0.0.1:9090"
	GrpcListenAddress string `` /* 236-byte string literal not displayed */
	// @gotags: kong:"default=batchcorp,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:"default=plumber1=http://127.0.0.1:2380,help='InitialCluster should contain comma separated list of key=value pairs of host:port entries for ALL peers in the cluster. (Example: server1=http://192.168.1.10:2380,server2=http://192.168.1.11:2380,server3=http://192.168.1.12:2380). IMPORTANT! The list should include the address of _this_ instance.',env='PLUMBER_SERVER_INITIAL_CLUSTER',required"
	InitialCluster string `` /* 501-byte string literal not displayed */
	// @gotags: kong:"default=http://127.0.0.1:2380,help='Address of _this_ plumber instance etcd server interface. Example: http://local-ip:2380',env='PLUMBER_SERVER_ADVERTISE_PEER_URL'"
	AdvertisePeerUrl string `` /* 283-byte string literal not displayed */
	// @gotags: kong:"default=http://127.0.0.1:2379,help='Address of _this_ plumber instance etcd client interface. Example: http://local-ip:2379',env='PLUMBER_SERVER_ADVERTISE_CLIENT_URL',required"
	AdvertiseClientUrl string `` /* 300-byte string literal not displayed */
	// @gotags: kong:"default=http://127.0.0.1:2380,help='Address that _this_ plumber instance etcd server should listen on. Example: http://local-ip:2380',env='PLUMBER_SERVER_LISTENER_PEER_URL'"
	ListenerPeerUrl string `` /* 288-byte string literal not displayed */
	// @gotags: kong:"default=http://127.0.0.1:2379,help='Address that _this_ plumber instance etcd client should listen on. Example: http://local-ip:2379',env='PLUMBER_SERVER_LISTENER_CLIENT_URL'"
	ListenerClientUrl string `` /* 296-byte string literal not displayed */
	// @gotags: kong:"default=secret,help='Secret token that ALL cluster members should use/share. If this token does not match on one of the plumber instances, this node will NOT be able to join the cluster.',env='PLUMBER_SERVER_PEER_TOKEN'"
	PeerToken string `` /* 316-byte string literal not displayed */
	// @gotags: kong:"help='VC-Service gRPC server address',default='https://vc-service.batch.sh'"
	VcserviceGrpcAddress string `` /* 207-byte string literal not displayed */
	// @gotags: kong:"help='VC-Service gRPC  server initial connection timeout',default=5"
	VcserviceGrpcTimeoutSeconds uint32 `` /* 223-byte string literal not displayed */
	// @gotags: kong:"help='Use gRPC insecure mode when talking to VC-Service'"
	VcserviceGrpcInsecure bool `` /* 192-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 */
	XXX_NoUnkeyedLiteral      struct{} `json:"-"`
	XXX_unrecognized          []byte   `json:"-"`
	XXX_sizecache             int32    `json:"-"`
}

func (*ServerOptions) Descriptor added in v0.0.49 

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

func (*ServerOptions) GetAdvertiseClientUrl added in v0.0.49 

func (m *ServerOptions) GetAdvertiseClientUrl() string

func (*ServerOptions) GetAdvertisePeerUrl added in v0.0.49 

func (m *ServerOptions) GetAdvertisePeerUrl() string

func (*ServerOptions) GetAuthToken added in v0.0.49 

func (m *ServerOptions) GetAuthToken() string

func (*ServerOptions) GetClusterId added in v0.0.49 

func (m *ServerOptions) GetClusterId() string

func (*ServerOptions) GetGrpcListenAddress added in v0.0.49 

func (m *ServerOptions) GetGrpcListenAddress() string

func (*ServerOptions) GetInitialCluster added in v0.0.49 

func (m *ServerOptions) GetInitialCluster() string

func (*ServerOptions) GetListenerClientUrl added in v0.0.49 

func (m *ServerOptions) GetListenerClientUrl() string

func (*ServerOptions) GetListenerPeerUrl added in v0.0.49 

func (m *ServerOptions) GetListenerPeerUrl() string

func (*ServerOptions) GetNodeId added in v0.0.49 

func (m *ServerOptions) GetNodeId() string

func (*ServerOptions) GetPeerToken added in v0.0.49 

func (m *ServerOptions) GetPeerToken() string

func (*ServerOptions) GetStatsDatabasePath added in v0.0.92 

func (m *ServerOptions) GetStatsDatabasePath() string

func (*ServerOptions) GetStatsFlushIntervalSeconds added in v0.0.92 

func (m *ServerOptions) GetStatsFlushIntervalSeconds() int32

func (*ServerOptions) GetVcserviceGrpcAddress added in v0.0.65 

func (m *ServerOptions) GetVcserviceGrpcAddress() string

func (*ServerOptions) GetVcserviceGrpcInsecure added in v0.0.65 

func (m *ServerOptions) GetVcserviceGrpcInsecure() bool

func (*ServerOptions) GetVcserviceGrpcTimeoutSeconds added in v0.0.65 

func (m *ServerOptions) GetVcserviceGrpcTimeoutSeconds() uint32

func (*ServerOptions) ProtoMessage added in v0.0.49 

func (*ServerOptions) ProtoMessage()

func (*ServerOptions) Reset added in v0.0.49 

func (m *ServerOptions) Reset()

func (*ServerOptions) String added in v0.0.49 

func (m *ServerOptions) String() string

func (*ServerOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *ServerOptions) XXX_DiscardUnknown()

func (*ServerOptions) XXX_Marshal added in v0.0.49 

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

func (*ServerOptions) XXX_Merge added in v0.0.49 

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

func (*ServerOptions) XXX_Size added in v0.0.49 

func (m *ServerOptions) XXX_Size() int

func (*ServerOptions) XXX_Unmarshal added in v0.0.49 

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

type Weekday added in v0.0.84 

type Weekday int32
const (
	Weekday_WEEKDAY_SUNDAY    Weekday = 0
	Weekday_WEEKDAY_MONDAY    Weekday = 1
	Weekday_WEEKDAY_TUESDAY   Weekday = 2
	Weekday_WEEKDAY_WEDNESDAY Weekday = 3
	Weekday_WEEKDAY_THURSDAY  Weekday = 4
	Weekday_WEEKDAY_FRIDAY    Weekday = 5
	Weekday_WEEKDAY_SATURDAY  Weekday = 6
)

func (Weekday) EnumDescriptor added in v0.0.84 

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

func (Weekday) String added in v0.0.84 

func (x Weekday) 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:"-"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteCLIOptions) Descriptor added in v0.0.49 

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

func (*WriteCLIOptions) GetInputAsJsonArray added in v0.0.49 

func (m *WriteCLIOptions) GetInputAsJsonArray() bool

func (*WriteCLIOptions) GetInputFile added in v0.0.49 

func (m *WriteCLIOptions) GetInputFile() string

func (*WriteCLIOptions) GetInputStdin added in v0.0.54 

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

func (*WriteCLIOptions) ProtoMessage added in v0.0.49 

func (*WriteCLIOptions) ProtoMessage()

func (*WriteCLIOptions) Reset added in v0.0.49 

func (m *WriteCLIOptions) Reset()

func (*WriteCLIOptions) String added in v0.0.49 

func (m *WriteCLIOptions) String() string

func (*WriteCLIOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteCLIOptions) XXX_DiscardUnknown()

func (*WriteCLIOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteCLIOptions) XXX_Merge added in v0.0.49 

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

func (*WriteCLIOptions) XXX_Size added in v0.0.49 

func (m *WriteCLIOptions) XXX_Size() int

func (*WriteCLIOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupAWSSNSOptions added in v0.0.49 

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

func (*WriteGroupAWSSNSOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupAWSSNSOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupAWSSNSOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupAWSSNSOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAWSSNSOptions) ProtoMessage()

func (*WriteGroupAWSSNSOptions) Reset added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) Reset()

func (*WriteGroupAWSSNSOptions) String added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) String() string

func (*WriteGroupAWSSNSOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) XXX_DiscardUnknown()

func (*WriteGroupAWSSNSOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupAWSSNSOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupAWSSNSOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupAWSSNSOptions) XXX_Size() int

func (*WriteGroupAWSSNSOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupAWSSQSOptions added in v0.0.49 

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

func (*WriteGroupAWSSQSOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupAWSSQSOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupAWSSQSOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupAWSSQSOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAWSSQSOptions) ProtoMessage()

func (*WriteGroupAWSSQSOptions) Reset added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) Reset()

func (*WriteGroupAWSSQSOptions) String added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) String() string

func (*WriteGroupAWSSQSOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) XXX_DiscardUnknown()

func (*WriteGroupAWSSQSOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupAWSSQSOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupAWSSQSOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupAWSSQSOptions) XXX_Size() int

func (*WriteGroupAWSSQSOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupActiveMQOptions added in v0.0.49 

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

func (*WriteGroupActiveMQOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupActiveMQOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupActiveMQOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupActiveMQOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupActiveMQOptions) ProtoMessage()

func (*WriteGroupActiveMQOptions) Reset added in v0.0.49 

func (m *WriteGroupActiveMQOptions) Reset()

func (*WriteGroupActiveMQOptions) String added in v0.0.49 

func (m *WriteGroupActiveMQOptions) String() string

func (*WriteGroupActiveMQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupActiveMQOptions) XXX_DiscardUnknown()

func (*WriteGroupActiveMQOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupActiveMQOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupActiveMQOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupActiveMQOptions) XXX_Size() int

func (*WriteGroupActiveMQOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupAzureEventHubOptions added in v0.0.49 

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

func (*WriteGroupAzureEventHubOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupAzureEventHubOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupAzureEventHubOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupAzureEventHubOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAzureEventHubOptions) ProtoMessage()

func (*WriteGroupAzureEventHubOptions) Reset added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) Reset()

func (*WriteGroupAzureEventHubOptions) String added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) String() string

func (*WriteGroupAzureEventHubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) XXX_DiscardUnknown()

func (*WriteGroupAzureEventHubOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupAzureEventHubOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupAzureEventHubOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupAzureEventHubOptions) XXX_Size() int

func (*WriteGroupAzureEventHubOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupAzureServiceBusOptions added in v0.0.49 

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

func (*WriteGroupAzureServiceBusOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupAzureServiceBusOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupAzureServiceBusOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupAzureServiceBusOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupAzureServiceBusOptions) ProtoMessage()

func (*WriteGroupAzureServiceBusOptions) Reset added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) Reset()

func (*WriteGroupAzureServiceBusOptions) String added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) String() string

func (*WriteGroupAzureServiceBusOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) XXX_DiscardUnknown()

func (*WriteGroupAzureServiceBusOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupAzureServiceBusOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupAzureServiceBusOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupAzureServiceBusOptions) XXX_Size() int

func (*WriteGroupAzureServiceBusOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupGCPPubSubOptions added in v0.0.49 

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

func (*WriteGroupGCPPubSubOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupGCPPubSubOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupGCPPubSubOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupGCPPubSubOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupGCPPubSubOptions) ProtoMessage()

func (*WriteGroupGCPPubSubOptions) Reset added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) Reset()

func (*WriteGroupGCPPubSubOptions) String added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) String() string

func (*WriteGroupGCPPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) XXX_DiscardUnknown()

func (*WriteGroupGCPPubSubOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupGCPPubSubOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupGCPPubSubOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupGCPPubSubOptions) XXX_Size() int

func (*WriteGroupGCPPubSubOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupKafkaOptions added in v0.0.49 

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

func (*WriteGroupKafkaOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupKafkaOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupKafkaOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupKafkaOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupKafkaOptions) ProtoMessage()

func (*WriteGroupKafkaOptions) Reset added in v0.0.49 

func (m *WriteGroupKafkaOptions) Reset()

func (*WriteGroupKafkaOptions) String added in v0.0.49 

func (m *WriteGroupKafkaOptions) String() string

func (*WriteGroupKafkaOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupKafkaOptions) XXX_DiscardUnknown()

func (*WriteGroupKafkaOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupKafkaOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupKafkaOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupKafkaOptions) XXX_Size() int

func (*WriteGroupKafkaOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupKubeMQQueueOptions added in v0.0.49 

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

func (*WriteGroupKubeMQQueueOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupKubeMQQueueOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupKubeMQQueueOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupKubeMQQueueOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupKubeMQQueueOptions) ProtoMessage()

func (*WriteGroupKubeMQQueueOptions) Reset added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) Reset()

func (*WriteGroupKubeMQQueueOptions) String added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) String() string

func (*WriteGroupKubeMQQueueOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) XXX_DiscardUnknown()

func (*WriteGroupKubeMQQueueOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupKubeMQQueueOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupKubeMQQueueOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupKubeMQQueueOptions) XXX_Size() int

func (*WriteGroupKubeMQQueueOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupMQTTOptions added in v0.0.49 

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

func (*WriteGroupMQTTOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupMQTTOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupMQTTOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupMQTTOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupMQTTOptions) ProtoMessage()

func (*WriteGroupMQTTOptions) Reset added in v0.0.49 

func (m *WriteGroupMQTTOptions) Reset()

func (*WriteGroupMQTTOptions) String added in v0.0.49 

func (m *WriteGroupMQTTOptions) String() string

func (*WriteGroupMQTTOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupMQTTOptions) XXX_DiscardUnknown()

func (*WriteGroupMQTTOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupMQTTOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupMQTTOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupMQTTOptions) XXX_Size() int

func (*WriteGroupMQTTOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupNSQOptions added in v0.0.49 

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

func (*WriteGroupNSQOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupNSQOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupNSQOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupNSQOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupNSQOptions) ProtoMessage()

func (*WriteGroupNSQOptions) Reset added in v0.0.49 

func (m *WriteGroupNSQOptions) Reset()

func (*WriteGroupNSQOptions) String added in v0.0.49 

func (m *WriteGroupNSQOptions) String() string

func (*WriteGroupNSQOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupNSQOptions) XXX_DiscardUnknown()

func (*WriteGroupNSQOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupNSQOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupNSQOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupNSQOptions) XXX_Size() int

func (*WriteGroupNSQOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupNatsOptions added in v0.0.49 

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

func (*WriteGroupNatsOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupNatsOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupNatsOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupNatsOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupNatsOptions) ProtoMessage()

func (*WriteGroupNatsOptions) Reset added in v0.0.49 

func (m *WriteGroupNatsOptions) Reset()

func (*WriteGroupNatsOptions) String added in v0.0.49 

func (m *WriteGroupNatsOptions) String() string

func (*WriteGroupNatsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupNatsOptions) XXX_DiscardUnknown()

func (*WriteGroupNatsOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupNatsOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupNatsOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupNatsOptions) XXX_Size() int

func (*WriteGroupNatsOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupNatsStreamingOptions added in v0.0.49 

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

func (*WriteGroupNatsStreamingOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupNatsStreamingOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupNatsStreamingOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupNatsStreamingOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupNatsStreamingOptions) ProtoMessage()

func (*WriteGroupNatsStreamingOptions) Reset added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) Reset()

func (*WriteGroupNatsStreamingOptions) String added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) String() string

func (*WriteGroupNatsStreamingOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) XXX_DiscardUnknown()

func (*WriteGroupNatsStreamingOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupNatsStreamingOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupNatsStreamingOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupNatsStreamingOptions) XXX_Size() int

func (*WriteGroupNatsStreamingOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupPulsarOptions added in v0.0.49 

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

func (*WriteGroupPulsarOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupPulsarOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupPulsarOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupPulsarOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupPulsarOptions) ProtoMessage()

func (*WriteGroupPulsarOptions) Reset added in v0.0.49 

func (m *WriteGroupPulsarOptions) Reset()

func (*WriteGroupPulsarOptions) String added in v0.0.49 

func (m *WriteGroupPulsarOptions) String() string

func (*WriteGroupPulsarOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupPulsarOptions) XXX_DiscardUnknown()

func (*WriteGroupPulsarOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupPulsarOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupPulsarOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupPulsarOptions) XXX_Size() int

func (*WriteGroupPulsarOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupRabbitOptions added in v0.0.49 

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

func (*WriteGroupRabbitOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupRabbitOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupRabbitOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupRabbitOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRabbitOptions) ProtoMessage()

func (*WriteGroupRabbitOptions) Reset added in v0.0.49 

func (m *WriteGroupRabbitOptions) Reset()

func (*WriteGroupRabbitOptions) String added in v0.0.49 

func (m *WriteGroupRabbitOptions) String() string

func (*WriteGroupRabbitOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupRabbitOptions) XXX_DiscardUnknown()

func (*WriteGroupRabbitOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupRabbitOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupRabbitOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupRabbitOptions) XXX_Size() int

func (*WriteGroupRabbitOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupRabbitStreamsOptions added in v0.0.49 

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

func (*WriteGroupRabbitStreamsOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupRabbitStreamsOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupRabbitStreamsOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupRabbitStreamsOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRabbitStreamsOptions) ProtoMessage()

func (*WriteGroupRabbitStreamsOptions) Reset added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) Reset()

func (*WriteGroupRabbitStreamsOptions) String added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) String() string

func (*WriteGroupRabbitStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) XXX_DiscardUnknown()

func (*WriteGroupRabbitStreamsOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupRabbitStreamsOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupRabbitStreamsOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupRabbitStreamsOptions) XXX_Size() int

func (*WriteGroupRabbitStreamsOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupRedisPubSubOptions added in v0.0.49 

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

func (*WriteGroupRedisPubSubOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupRedisPubSubOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupRedisPubSubOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupRedisPubSubOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRedisPubSubOptions) ProtoMessage()

func (*WriteGroupRedisPubSubOptions) Reset added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) Reset()

func (*WriteGroupRedisPubSubOptions) String added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) String() string

func (*WriteGroupRedisPubSubOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) XXX_DiscardUnknown()

func (*WriteGroupRedisPubSubOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupRedisPubSubOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupRedisPubSubOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupRedisPubSubOptions) XXX_Size() int

func (*WriteGroupRedisPubSubOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteGroupRedisStreamsOptions added in v0.0.49 

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

func (*WriteGroupRedisStreamsOptions) Descriptor added in v0.0.49 

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

func (*WriteGroupRedisStreamsOptions) GetArgs added in v0.0.49 

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

func (*WriteGroupRedisStreamsOptions) GetXConn added in v0.0.49 

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

func (*WriteGroupRedisStreamsOptions) ProtoMessage added in v0.0.49 

func (*WriteGroupRedisStreamsOptions) ProtoMessage()

func (*WriteGroupRedisStreamsOptions) Reset added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) Reset()

func (*WriteGroupRedisStreamsOptions) String added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) String() string

func (*WriteGroupRedisStreamsOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) XXX_DiscardUnknown()

func (*WriteGroupRedisStreamsOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteGroupRedisStreamsOptions) XXX_Merge added in v0.0.49 

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

func (*WriteGroupRedisStreamsOptions) XXX_Size added in v0.0.49 

func (m *WriteGroupRedisStreamsOptions) XXX_Size() int

func (*WriteGroupRedisStreamsOptions) XXX_Unmarshal added in v0.0.49 

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

type WriteOptions added in v0.0.49 

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

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

func (*WriteOptions) Descriptor added in v0.0.49 

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

func (*WriteOptions) GetActivemq added in v0.0.49 

func (m *WriteOptions) GetActivemq() *WriteGroupActiveMQOptions

func (*WriteOptions) GetAwssns added in v0.0.49 

func (m *WriteOptions) GetAwssns() *WriteGroupAWSSNSOptions

func (*WriteOptions) GetAwssqs added in v0.0.49 

func (m *WriteOptions) GetAwssqs() *WriteGroupAWSSQSOptions

func (*WriteOptions) GetAzureEventHub added in v0.0.49 

func (m *WriteOptions) GetAzureEventHub() *WriteGroupAzureEventHubOptions

func (*WriteOptions) GetAzureServiceBus added in v0.0.49 

func (m *WriteOptions) GetAzureServiceBus() *WriteGroupAzureServiceBusOptions

func (*WriteOptions) GetConnectionId added in v0.0.49 

func (m *WriteOptions) GetConnectionId() string

func (*WriteOptions) GetEncodeOptions added in v0.0.50 

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

func (*WriteOptions) GetGcpPubsub added in v0.0.49 

func (m *WriteOptions) GetGcpPubsub() *WriteGroupGCPPubSubOptions

func (*WriteOptions) GetKafka added in v0.0.49 

func (m *WriteOptions) GetKafka() *WriteGroupKafkaOptions

func (*WriteOptions) GetKubemqQueue added in v0.0.49 

func (m *WriteOptions) GetKubemqQueue() *WriteGroupKubeMQQueueOptions

func (*WriteOptions) GetMqtt added in v0.0.49 

func (m *WriteOptions) GetMqtt() *WriteGroupMQTTOptions

func (*WriteOptions) GetNats added in v0.0.49 

func (m *WriteOptions) GetNats() *WriteGroupNatsOptions

func (*WriteOptions) GetNatsStreaming added in v0.0.49 

func (m *WriteOptions) GetNatsStreaming() *WriteGroupNatsStreamingOptions

func (*WriteOptions) GetNsq added in v0.0.49 

func (m *WriteOptions) GetNsq() *WriteGroupNSQOptions

func (*WriteOptions) GetPulsar added in v0.0.49 

func (m *WriteOptions) GetPulsar() *WriteGroupPulsarOptions

func (*WriteOptions) GetRabbit added in v0.0.49 

func (m *WriteOptions) GetRabbit() *WriteGroupRabbitOptions

func (*WriteOptions) GetRabbitStreams added in v0.0.49 

func (m *WriteOptions) GetRabbitStreams() *WriteGroupRabbitStreamsOptions

func (*WriteOptions) GetRecord added in v0.0.49 

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

func (*WriteOptions) GetRedisPubsub added in v0.0.49 

func (m *WriteOptions) GetRedisPubsub() *WriteGroupRedisPubSubOptions

func (*WriteOptions) GetRedisStreams added in v0.0.49 

func (m *WriteOptions) GetRedisStreams() *WriteGroupRedisStreamsOptions

func (*WriteOptions) GetXCliOptions added in v0.0.49 

func (m *WriteOptions) GetXCliOptions() *WriteCLIOptions

func (*WriteOptions) ProtoMessage added in v0.0.49 

func (*WriteOptions) ProtoMessage()

func (*WriteOptions) Reset added in v0.0.49 

func (m *WriteOptions) Reset()

func (*WriteOptions) String added in v0.0.49 

func (m *WriteOptions) String() string

func (*WriteOptions) XXX_DiscardUnknown added in v0.0.49 

func (m *WriteOptions) XXX_DiscardUnknown()

func (*WriteOptions) XXX_Marshal added in v0.0.49 

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

func (*WriteOptions) XXX_Merge added in v0.0.49 

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

func (*WriteOptions) XXX_Size added in v0.0.49 

func (m *WriteOptions) XXX_Size() int

func (*WriteOptions) XXX_Unmarshal added in v0.0.49 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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