Documentation ¶
Index ¶
- Variables
- func RegisterPlumberServerServer(s *grpc.Server, srv PlumberServerServer)
- type Connection
- func (*Connection) Descriptor() ([]byte, []int)
- func (m *Connection) GetConn() isConnection_Conn
- func (m *Connection) GetKafka() *conns.Kafka
- func (m *Connection) GetName() string
- func (m *Connection) GetNotes() string
- func (*Connection) ProtoMessage()
- func (m *Connection) Reset()
- func (m *Connection) String() string
- func (m *Connection) XXX_DiscardUnknown()
- func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Connection) XXX_Merge(src proto.Message)
- func (*Connection) XXX_OneofWrappers() []interface{}
- func (m *Connection) XXX_Size() int
- func (m *Connection) XXX_Unmarshal(b []byte) error
- type Connection_Kafka
- type CreateConnectionRequest
- func (*CreateConnectionRequest) Descriptor() ([]byte, []int)
- func (m *CreateConnectionRequest) GetAuth() *common.Auth
- func (m *CreateConnectionRequest) GetConnection() *Connection
- func (*CreateConnectionRequest) ProtoMessage()
- func (m *CreateConnectionRequest) Reset()
- func (m *CreateConnectionRequest) String() string
- func (m *CreateConnectionRequest) XXX_DiscardUnknown()
- func (m *CreateConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateConnectionRequest) XXX_Merge(src proto.Message)
- func (m *CreateConnectionRequest) XXX_Size() int
- func (m *CreateConnectionRequest) XXX_Unmarshal(b []byte) error
- type CreateConnectionResponse
- func (*CreateConnectionResponse) Descriptor() ([]byte, []int)
- func (m *CreateConnectionResponse) GetConnectionId() string
- func (*CreateConnectionResponse) ProtoMessage()
- func (m *CreateConnectionResponse) Reset()
- func (m *CreateConnectionResponse) String() string
- func (m *CreateConnectionResponse) XXX_DiscardUnknown()
- func (m *CreateConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateConnectionResponse) XXX_Merge(src proto.Message)
- func (m *CreateConnectionResponse) XXX_Size() int
- func (m *CreateConnectionResponse) XXX_Unmarshal(b []byte) error
- type CreateRelayRequest
- func (*CreateRelayRequest) Descriptor() ([]byte, []int)
- func (m *CreateRelayRequest) GetArgs() isCreateRelayRequest_Args
- func (m *CreateRelayRequest) GetAuth() *common.Auth
- func (m *CreateRelayRequest) GetKafka() *args.Kafka
- func (m *CreateRelayRequest) GetRelay() *Relay
- func (*CreateRelayRequest) ProtoMessage()
- func (m *CreateRelayRequest) Reset()
- func (m *CreateRelayRequest) String() string
- func (m *CreateRelayRequest) XXX_DiscardUnknown()
- func (m *CreateRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRelayRequest) XXX_Merge(src proto.Message)
- func (*CreateRelayRequest) XXX_OneofWrappers() []interface{}
- func (m *CreateRelayRequest) XXX_Size() int
- func (m *CreateRelayRequest) XXX_Unmarshal(b []byte) error
- type CreateRelayRequest_Kafka
- type CreateRelayResponse
- func (*CreateRelayResponse) Descriptor() ([]byte, []int)
- func (m *CreateRelayResponse) GetRelayId() string
- func (m *CreateRelayResponse) GetStatus() *common.Status
- func (*CreateRelayResponse) ProtoMessage()
- func (m *CreateRelayResponse) Reset()
- func (m *CreateRelayResponse) String() string
- func (m *CreateRelayResponse) XXX_DiscardUnknown()
- func (m *CreateRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRelayResponse) XXX_Merge(src proto.Message)
- func (m *CreateRelayResponse) XXX_Size() int
- func (m *CreateRelayResponse) XXX_Unmarshal(b []byte) error
- type DeleteConnectionRequest
- func (*DeleteConnectionRequest) Descriptor() ([]byte, []int)
- func (m *DeleteConnectionRequest) GetAuth() *common.Auth
- func (m *DeleteConnectionRequest) GetConnectionId() string
- func (*DeleteConnectionRequest) ProtoMessage()
- func (m *DeleteConnectionRequest) Reset()
- func (m *DeleteConnectionRequest) String() string
- func (m *DeleteConnectionRequest) XXX_DiscardUnknown()
- func (m *DeleteConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteConnectionRequest) XXX_Merge(src proto.Message)
- func (m *DeleteConnectionRequest) XXX_Size() int
- func (m *DeleteConnectionRequest) XXX_Unmarshal(b []byte) error
- type DeleteConnectionResponse
- func (*DeleteConnectionResponse) Descriptor() ([]byte, []int)
- func (m *DeleteConnectionResponse) GetStatus() *common.Status
- func (*DeleteConnectionResponse) ProtoMessage()
- func (m *DeleteConnectionResponse) Reset()
- func (m *DeleteConnectionResponse) String() string
- func (m *DeleteConnectionResponse) XXX_DiscardUnknown()
- func (m *DeleteConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteConnectionResponse) XXX_Merge(src proto.Message)
- func (m *DeleteConnectionResponse) XXX_Size() int
- func (m *DeleteConnectionResponse) XXX_Unmarshal(b []byte) error
- type DeleteRelayRequest
- func (*DeleteRelayRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRelayRequest) GetAuth() *common.Auth
- func (m *DeleteRelayRequest) GetRelayId() string
- func (*DeleteRelayRequest) ProtoMessage()
- func (m *DeleteRelayRequest) Reset()
- func (m *DeleteRelayRequest) String() string
- func (m *DeleteRelayRequest) XXX_DiscardUnknown()
- func (m *DeleteRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRelayRequest) XXX_Merge(src proto.Message)
- func (m *DeleteRelayRequest) XXX_Size() int
- func (m *DeleteRelayRequest) XXX_Unmarshal(b []byte) error
- type DeleteRelayResponse
- func (*DeleteRelayResponse) Descriptor() ([]byte, []int)
- func (m *DeleteRelayResponse) GetStatus() *common.Status
- func (*DeleteRelayResponse) ProtoMessage()
- func (m *DeleteRelayResponse) Reset()
- func (m *DeleteRelayResponse) String() string
- func (m *DeleteRelayResponse) XXX_DiscardUnknown()
- func (m *DeleteRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRelayResponse) XXX_Merge(src proto.Message)
- func (m *DeleteRelayResponse) XXX_Size() int
- func (m *DeleteRelayResponse) XXX_Unmarshal(b []byte) error
- type GetAllConnectionsRequest
- func (*GetAllConnectionsRequest) Descriptor() ([]byte, []int)
- func (m *GetAllConnectionsRequest) GetAuth() *common.Auth
- func (*GetAllConnectionsRequest) ProtoMessage()
- func (m *GetAllConnectionsRequest) Reset()
- func (m *GetAllConnectionsRequest) String() string
- func (m *GetAllConnectionsRequest) XXX_DiscardUnknown()
- func (m *GetAllConnectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAllConnectionsRequest) XXX_Merge(src proto.Message)
- func (m *GetAllConnectionsRequest) XXX_Size() int
- func (m *GetAllConnectionsRequest) XXX_Unmarshal(b []byte) error
- type GetAllConnectionsResponse
- func (*GetAllConnectionsResponse) Descriptor() ([]byte, []int)
- func (m *GetAllConnectionsResponse) GetConnections() []*Connection
- func (*GetAllConnectionsResponse) ProtoMessage()
- func (m *GetAllConnectionsResponse) Reset()
- func (m *GetAllConnectionsResponse) String() string
- func (m *GetAllConnectionsResponse) XXX_DiscardUnknown()
- func (m *GetAllConnectionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAllConnectionsResponse) XXX_Merge(src proto.Message)
- func (m *GetAllConnectionsResponse) XXX_Size() int
- func (m *GetAllConnectionsResponse) XXX_Unmarshal(b []byte) error
- type GetAllRelaysRequest
- func (*GetAllRelaysRequest) Descriptor() ([]byte, []int)
- func (m *GetAllRelaysRequest) GetAuth() *common.Auth
- func (*GetAllRelaysRequest) ProtoMessage()
- func (m *GetAllRelaysRequest) Reset()
- func (m *GetAllRelaysRequest) String() string
- func (m *GetAllRelaysRequest) XXX_DiscardUnknown()
- func (m *GetAllRelaysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAllRelaysRequest) XXX_Merge(src proto.Message)
- func (m *GetAllRelaysRequest) XXX_Size() int
- func (m *GetAllRelaysRequest) XXX_Unmarshal(b []byte) error
- type GetAllRelaysResponse
- func (*GetAllRelaysResponse) Descriptor() ([]byte, []int)
- func (m *GetAllRelaysResponse) GetRelays() []*Relay
- func (m *GetAllRelaysResponse) GetStatus() *common.Status
- func (*GetAllRelaysResponse) ProtoMessage()
- func (m *GetAllRelaysResponse) Reset()
- func (m *GetAllRelaysResponse) String() string
- func (m *GetAllRelaysResponse) XXX_DiscardUnknown()
- func (m *GetAllRelaysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAllRelaysResponse) XXX_Merge(src proto.Message)
- func (m *GetAllRelaysResponse) XXX_Size() int
- func (m *GetAllRelaysResponse) XXX_Unmarshal(b []byte) error
- type GetConnectionRequest
- func (*GetConnectionRequest) Descriptor() ([]byte, []int)
- func (m *GetConnectionRequest) GetAuth() *common.Auth
- func (m *GetConnectionRequest) GetConnectionId() string
- func (*GetConnectionRequest) ProtoMessage()
- func (m *GetConnectionRequest) Reset()
- func (m *GetConnectionRequest) String() string
- func (m *GetConnectionRequest) XXX_DiscardUnknown()
- func (m *GetConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetConnectionRequest) XXX_Merge(src proto.Message)
- func (m *GetConnectionRequest) XXX_Size() int
- func (m *GetConnectionRequest) XXX_Unmarshal(b []byte) error
- type GetConnectionResponse
- func (*GetConnectionResponse) Descriptor() ([]byte, []int)
- func (m *GetConnectionResponse) GetConnection() *Connection
- func (*GetConnectionResponse) ProtoMessage()
- func (m *GetConnectionResponse) Reset()
- func (m *GetConnectionResponse) String() string
- func (m *GetConnectionResponse) XXX_DiscardUnknown()
- func (m *GetConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetConnectionResponse) XXX_Merge(src proto.Message)
- func (m *GetConnectionResponse) XXX_Size() int
- func (m *GetConnectionResponse) XXX_Unmarshal(b []byte) error
- type GetRelayRequest
- func (*GetRelayRequest) Descriptor() ([]byte, []int)
- func (m *GetRelayRequest) GetAuth() *common.Auth
- func (m *GetRelayRequest) GetRelayId() string
- func (*GetRelayRequest) ProtoMessage()
- func (m *GetRelayRequest) Reset()
- func (m *GetRelayRequest) String() string
- func (m *GetRelayRequest) XXX_DiscardUnknown()
- func (m *GetRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRelayRequest) XXX_Merge(src proto.Message)
- func (m *GetRelayRequest) XXX_Size() int
- func (m *GetRelayRequest) XXX_Unmarshal(b []byte) error
- type GetRelayResponse
- func (*GetRelayResponse) Descriptor() ([]byte, []int)
- func (m *GetRelayResponse) GetRelay() *Relay
- func (m *GetRelayResponse) GetStatus() *common.Status
- func (*GetRelayResponse) ProtoMessage()
- func (m *GetRelayResponse) Reset()
- func (m *GetRelayResponse) String() string
- func (m *GetRelayResponse) XXX_DiscardUnknown()
- func (m *GetRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRelayResponse) XXX_Merge(src proto.Message)
- func (m *GetRelayResponse) XXX_Size() int
- func (m *GetRelayResponse) XXX_Unmarshal(b []byte) error
- type PlumberServerClient
- type PlumberServerServer
- type PlumberServer_StartReadClient
- type PlumberServer_StartReadServer
- type ReadOptions
- func (*ReadOptions) Descriptor() ([]byte, []int)
- func (*ReadOptions) ProtoMessage()
- func (m *ReadOptions) Reset()
- func (m *ReadOptions) String() string
- func (m *ReadOptions) XXX_DiscardUnknown()
- func (m *ReadOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadOptions) XXX_Merge(src proto.Message)
- func (m *ReadOptions) XXX_Size() int
- func (m *ReadOptions) XXX_Unmarshal(b []byte) error
- type ReadOptions_Type
- type Relay
- func (*Relay) Descriptor() ([]byte, []int)
- func (m *Relay) GetArgs() isRelay_Args
- func (m *Relay) GetBatchCollectionToken() string
- func (m *Relay) GetBatchMaxRetry() int32
- func (m *Relay) GetBatchSize() int32
- func (m *Relay) GetBatchshGrpcAddress() string
- func (m *Relay) GetBatchshGrpcDisableTls() bool
- func (m *Relay) GetBatchshGrpcTimeout() bool
- func (m *Relay) GetConnectionId() string
- func (m *Relay) GetKafka() *args.Kafka
- func (*Relay) ProtoMessage()
- func (m *Relay) Reset()
- func (m *Relay) String() string
- func (m *Relay) XXX_DiscardUnknown()
- func (m *Relay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Relay) XXX_Merge(src proto.Message)
- func (*Relay) XXX_OneofWrappers() []interface{}
- func (m *Relay) XXX_Size() int
- func (m *Relay) XXX_Unmarshal(b []byte) error
- type Relay_Kafka
- type SampleOptions
- func (*SampleOptions) Descriptor() ([]byte, []int)
- func (m *SampleOptions) GetSampleInterval() SampleOptions_Interval
- func (m *SampleOptions) GetSampleRate() uint32
- func (*SampleOptions) ProtoMessage()
- func (m *SampleOptions) Reset()
- func (m *SampleOptions) String() string
- func (m *SampleOptions) XXX_DiscardUnknown()
- func (m *SampleOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SampleOptions) XXX_Merge(src proto.Message)
- func (m *SampleOptions) XXX_Size() int
- func (m *SampleOptions) XXX_Unmarshal(b []byte) error
- type SampleOptions_Interval
- type StartReadRequest
- func (*StartReadRequest) Descriptor() ([]byte, []int)
- func (m *StartReadRequest) GetArgs() isStartReadRequest_Args
- func (m *StartReadRequest) GetAuth() *common.Auth
- func (m *StartReadRequest) GetConnectionId() string
- func (m *StartReadRequest) GetDecodeOptions() *encoding.Options
- func (m *StartReadRequest) GetKafka() *args.Kafka
- func (m *StartReadRequest) GetReadOptions() *ReadOptions
- func (m *StartReadRequest) GetSampleOptions() *SampleOptions
- func (*StartReadRequest) ProtoMessage()
- func (m *StartReadRequest) Reset()
- func (m *StartReadRequest) String() string
- func (m *StartReadRequest) XXX_DiscardUnknown()
- func (m *StartReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartReadRequest) XXX_Merge(src proto.Message)
- func (*StartReadRequest) XXX_OneofWrappers() []interface{}
- func (m *StartReadRequest) XXX_Size() int
- func (m *StartReadRequest) XXX_Unmarshal(b []byte) error
- type StartReadRequest_Kafka
- type StartReadResponse
- func (*StartReadResponse) Descriptor() ([]byte, []int)
- func (m *StartReadResponse) GetMessages() []*records.Message
- func (m *StartReadResponse) GetReadId() string
- func (m *StartReadResponse) GetStatus() *common.Status
- func (*StartReadResponse) ProtoMessage()
- func (m *StartReadResponse) Reset()
- func (m *StartReadResponse) String() string
- func (m *StartReadResponse) XXX_DiscardUnknown()
- func (m *StartReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartReadResponse) XXX_Merge(src proto.Message)
- func (m *StartReadResponse) XXX_Size() int
- func (m *StartReadResponse) XXX_Unmarshal(b []byte) error
- type StopReadRequest
- func (*StopReadRequest) Descriptor() ([]byte, []int)
- func (m *StopReadRequest) GetAuth() *common.Auth
- func (m *StopReadRequest) GetReadId() string
- func (*StopReadRequest) ProtoMessage()
- func (m *StopReadRequest) Reset()
- func (m *StopReadRequest) String() string
- func (m *StopReadRequest) XXX_DiscardUnknown()
- func (m *StopReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopReadRequest) XXX_Merge(src proto.Message)
- func (m *StopReadRequest) XXX_Size() int
- func (m *StopReadRequest) XXX_Unmarshal(b []byte) error
- type StopReadResponse
- func (*StopReadResponse) Descriptor() ([]byte, []int)
- func (m *StopReadResponse) GetStatus() *common.Status
- func (*StopReadResponse) ProtoMessage()
- func (m *StopReadResponse) Reset()
- func (m *StopReadResponse) String() string
- func (m *StopReadResponse) XXX_DiscardUnknown()
- func (m *StopReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopReadResponse) XXX_Merge(src proto.Message)
- func (m *StopReadResponse) XXX_Size() int
- func (m *StopReadResponse) XXX_Unmarshal(b []byte) error
- type StopRelayRequest
- func (*StopRelayRequest) Descriptor() ([]byte, []int)
- func (m *StopRelayRequest) GetAuth() *common.Auth
- func (m *StopRelayRequest) GetRelayId() string
- func (*StopRelayRequest) ProtoMessage()
- func (m *StopRelayRequest) Reset()
- func (m *StopRelayRequest) String() string
- func (m *StopRelayRequest) XXX_DiscardUnknown()
- func (m *StopRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopRelayRequest) XXX_Merge(src proto.Message)
- func (m *StopRelayRequest) XXX_Size() int
- func (m *StopRelayRequest) XXX_Unmarshal(b []byte) error
- type StopRelayResponse
- func (*StopRelayResponse) Descriptor() ([]byte, []int)
- func (m *StopRelayResponse) GetStatus() *common.Status
- func (*StopRelayResponse) ProtoMessage()
- func (m *StopRelayResponse) Reset()
- func (m *StopRelayResponse) String() string
- func (m *StopRelayResponse) XXX_DiscardUnknown()
- func (m *StopRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopRelayResponse) XXX_Merge(src proto.Message)
- func (m *StopRelayResponse) XXX_Size() int
- func (m *StopRelayResponse) XXX_Unmarshal(b []byte) error
- type TestConnectionRequest
- func (*TestConnectionRequest) Descriptor() ([]byte, []int)
- func (m *TestConnectionRequest) GetAuth() *common.Auth
- func (m *TestConnectionRequest) GetConnection() *Connection
- func (*TestConnectionRequest) ProtoMessage()
- func (m *TestConnectionRequest) Reset()
- func (m *TestConnectionRequest) String() string
- func (m *TestConnectionRequest) XXX_DiscardUnknown()
- func (m *TestConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TestConnectionRequest) XXX_Merge(src proto.Message)
- func (m *TestConnectionRequest) XXX_Size() int
- func (m *TestConnectionRequest) XXX_Unmarshal(b []byte) error
- type TestConnectionResponse
- func (*TestConnectionResponse) Descriptor() ([]byte, []int)
- func (m *TestConnectionResponse) GetStatus() *common.Status
- func (*TestConnectionResponse) ProtoMessage()
- func (m *TestConnectionResponse) Reset()
- func (m *TestConnectionResponse) String() string
- func (m *TestConnectionResponse) XXX_DiscardUnknown()
- func (m *TestConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TestConnectionResponse) XXX_Merge(src proto.Message)
- func (m *TestConnectionResponse) XXX_Size() int
- func (m *TestConnectionResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedPlumberServerServer
- func (*UnimplementedPlumberServerServer) CreateConnection(ctx context.Context, req *CreateConnectionRequest) (*CreateConnectionResponse, error)
- func (*UnimplementedPlumberServerServer) CreateRelay(ctx context.Context, req *CreateRelayRequest) (*CreateRelayResponse, error)
- func (*UnimplementedPlumberServerServer) DeleteConnection(ctx context.Context, req *DeleteConnectionRequest) (*DeleteConnectionResponse, error)
- func (*UnimplementedPlumberServerServer) DeleteRelay(ctx context.Context, req *DeleteRelayRequest) (*DeleteRelayResponse, error)
- func (*UnimplementedPlumberServerServer) GetAllConnections(ctx context.Context, req *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error)
- func (*UnimplementedPlumberServerServer) GetConnection(ctx context.Context, req *GetConnectionRequest) (*GetConnectionResponse, error)
- func (*UnimplementedPlumberServerServer) StartRead(req *StartReadRequest, srv PlumberServer_StartReadServer) error
- func (*UnimplementedPlumberServerServer) StopRead(ctx context.Context, req *StopReadRequest) (*StopReadResponse, error)
- func (*UnimplementedPlumberServerServer) StopRelay(ctx context.Context, req *StopRelayRequest) (*StopRelayResponse, error)
- func (*UnimplementedPlumberServerServer) TestConnection(ctx context.Context, req *TestConnectionRequest) (*TestConnectionResponse, error)
- func (*UnimplementedPlumberServerServer) UpdateConnection(ctx context.Context, req *UpdateConnectionRequest) (*UpdateConnectionResponse, error)
- func (*UnimplementedPlumberServerServer) UpdateRelay(ctx context.Context, req *UpdateRelayRequest) (*UpdateRelayResponse, error)
- func (*UnimplementedPlumberServerServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)
- type UpdateConnectionRequest
- func (*UpdateConnectionRequest) Descriptor() ([]byte, []int)
- func (m *UpdateConnectionRequest) GetAuth() *common.Auth
- func (m *UpdateConnectionRequest) GetConnection() *Connection
- func (m *UpdateConnectionRequest) GetConnectionId() string
- func (*UpdateConnectionRequest) ProtoMessage()
- func (m *UpdateConnectionRequest) Reset()
- func (m *UpdateConnectionRequest) String() string
- func (m *UpdateConnectionRequest) XXX_DiscardUnknown()
- func (m *UpdateConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateConnectionRequest) XXX_Merge(src proto.Message)
- func (m *UpdateConnectionRequest) XXX_Size() int
- func (m *UpdateConnectionRequest) XXX_Unmarshal(b []byte) error
- type UpdateConnectionResponse
- func (*UpdateConnectionResponse) Descriptor() ([]byte, []int)
- func (m *UpdateConnectionResponse) GetStatus() *common.Status
- func (*UpdateConnectionResponse) ProtoMessage()
- func (m *UpdateConnectionResponse) Reset()
- func (m *UpdateConnectionResponse) String() string
- func (m *UpdateConnectionResponse) XXX_DiscardUnknown()
- func (m *UpdateConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateConnectionResponse) XXX_Merge(src proto.Message)
- func (m *UpdateConnectionResponse) XXX_Size() int
- func (m *UpdateConnectionResponse) XXX_Unmarshal(b []byte) error
- type UpdateRelayRequest
- func (*UpdateRelayRequest) Descriptor() ([]byte, []int)
- func (m *UpdateRelayRequest) GetAuth() *common.Auth
- func (m *UpdateRelayRequest) GetRelay() *Relay
- func (m *UpdateRelayRequest) GetRelayId() string
- func (*UpdateRelayRequest) ProtoMessage()
- func (m *UpdateRelayRequest) Reset()
- func (m *UpdateRelayRequest) String() string
- func (m *UpdateRelayRequest) XXX_DiscardUnknown()
- func (m *UpdateRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateRelayRequest) XXX_Merge(src proto.Message)
- func (m *UpdateRelayRequest) XXX_Size() int
- func (m *UpdateRelayRequest) XXX_Unmarshal(b []byte) error
- type UpdateRelayResponse
- func (*UpdateRelayResponse) Descriptor() ([]byte, []int)
- func (m *UpdateRelayResponse) GetStatus() *common.Status
- func (*UpdateRelayResponse) ProtoMessage()
- func (m *UpdateRelayResponse) Reset()
- func (m *UpdateRelayResponse) String() string
- func (m *UpdateRelayResponse) XXX_DiscardUnknown()
- func (m *UpdateRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateRelayResponse) XXX_Merge(src proto.Message)
- func (m *UpdateRelayResponse) XXX_Size() int
- func (m *UpdateRelayResponse) XXX_Unmarshal(b []byte) error
- type WriteRecord
- func (*WriteRecord) Descriptor() ([]byte, []int)
- func (m *WriteRecord) GetKafka() *records.Kafka
- func (m *WriteRecord) GetRecords() isWriteRecord_Records
- func (*WriteRecord) ProtoMessage()
- func (m *WriteRecord) Reset()
- func (m *WriteRecord) String() string
- func (m *WriteRecord) XXX_DiscardUnknown()
- func (m *WriteRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteRecord) XXX_Merge(src proto.Message)
- func (*WriteRecord) XXX_OneofWrappers() []interface{}
- func (m *WriteRecord) XXX_Size() int
- func (m *WriteRecord) XXX_Unmarshal(b []byte) error
- type WriteRecord_Kafka
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)
- func (m *WriteRequest) GetAuth() *common.Auth
- func (m *WriteRequest) GetConnectionId() string
- func (m *WriteRequest) GetEncodeOptions() *encoding.Options
- func (m *WriteRequest) GetRecords() []*WriteRecord
- func (*WriteRequest) ProtoMessage()
- func (m *WriteRequest) Reset()
- func (m *WriteRequest) String() string
- func (m *WriteRequest) XXX_DiscardUnknown()
- func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteRequest) XXX_Merge(src proto.Message)
- func (m *WriteRequest) XXX_Size() int
- func (m *WriteRequest) XXX_Unmarshal(b []byte) error
- type WriteResponse
- func (*WriteResponse) Descriptor() ([]byte, []int)
- func (m *WriteResponse) GetStatus() *common.Status
- func (*WriteResponse) ProtoMessage()
- func (m *WriteResponse) Reset()
- func (m *WriteResponse) String() string
- func (m *WriteResponse) XXX_DiscardUnknown()
- func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteResponse) XXX_Merge(src proto.Message)
- func (m *WriteResponse) XXX_Size() int
- func (m *WriteResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ReadOptions_Type_name = map[int32]string{
0: "ONE_TIME",
1: "CONTINUOUS",
}
var ReadOptions_Type_value = map[string]int32{
"ONE_TIME": 0,
"CONTINUOUS": 1,
}
var SampleOptions_Interval_name = map[int32]string{
0: "SECOND",
1: "MINUTE",
2: "HOUR",
}
var SampleOptions_Interval_value = map[string]int32{
"SECOND": 0,
"MINUTE": 1,
"HOUR": 2,
}
Functions ¶
func RegisterPlumberServerServer ¶
func RegisterPlumberServerServer(s *grpc.Server, srv PlumberServerServer)
Types ¶
type Connection ¶
type Connection 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: // *Connection_Kafka Conn isConnection_Conn `protobuf_oneof:"conn"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Connection) Descriptor ¶
func (*Connection) Descriptor() ([]byte, []int)
func (*Connection) GetConn ¶
func (m *Connection) GetConn() isConnection_Conn
func (*Connection) GetKafka ¶
func (m *Connection) GetKafka() *conns.Kafka
func (*Connection) GetName ¶
func (m *Connection) GetName() string
func (*Connection) GetNotes ¶
func (m *Connection) GetNotes() string
func (*Connection) ProtoMessage ¶
func (*Connection) ProtoMessage()
func (*Connection) Reset ¶
func (m *Connection) Reset()
func (*Connection) String ¶
func (m *Connection) String() string
func (*Connection) XXX_DiscardUnknown ¶
func (m *Connection) XXX_DiscardUnknown()
func (*Connection) XXX_Marshal ¶
func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Connection) XXX_Merge ¶
func (m *Connection) XXX_Merge(src proto.Message)
func (*Connection) XXX_OneofWrappers ¶
func (*Connection) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Connection) XXX_Size ¶
func (m *Connection) XXX_Size() int
func (*Connection) XXX_Unmarshal ¶
func (m *Connection) XXX_Unmarshal(b []byte) error
type Connection_Kafka ¶
type CreateConnectionRequest ¶
type CreateConnectionRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` Connection *Connection `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateConnectionRequest) Descriptor ¶
func (*CreateConnectionRequest) Descriptor() ([]byte, []int)
func (*CreateConnectionRequest) GetAuth ¶
func (m *CreateConnectionRequest) GetAuth() *common.Auth
func (*CreateConnectionRequest) GetConnection ¶
func (m *CreateConnectionRequest) GetConnection() *Connection
func (*CreateConnectionRequest) ProtoMessage ¶
func (*CreateConnectionRequest) ProtoMessage()
func (*CreateConnectionRequest) Reset ¶
func (m *CreateConnectionRequest) Reset()
func (*CreateConnectionRequest) String ¶
func (m *CreateConnectionRequest) String() string
func (*CreateConnectionRequest) XXX_DiscardUnknown ¶
func (m *CreateConnectionRequest) XXX_DiscardUnknown()
func (*CreateConnectionRequest) XXX_Marshal ¶
func (m *CreateConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateConnectionRequest) XXX_Merge ¶
func (m *CreateConnectionRequest) XXX_Merge(src proto.Message)
func (*CreateConnectionRequest) XXX_Size ¶
func (m *CreateConnectionRequest) XXX_Size() int
func (*CreateConnectionRequest) XXX_Unmarshal ¶
func (m *CreateConnectionRequest) XXX_Unmarshal(b []byte) error
type CreateConnectionResponse ¶
type CreateConnectionResponse struct { // Set with uuid that represents connection if create is successful ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateConnectionResponse) Descriptor ¶
func (*CreateConnectionResponse) Descriptor() ([]byte, []int)
func (*CreateConnectionResponse) GetConnectionId ¶
func (m *CreateConnectionResponse) GetConnectionId() string
func (*CreateConnectionResponse) ProtoMessage ¶
func (*CreateConnectionResponse) ProtoMessage()
func (*CreateConnectionResponse) Reset ¶
func (m *CreateConnectionResponse) Reset()
func (*CreateConnectionResponse) String ¶
func (m *CreateConnectionResponse) String() string
func (*CreateConnectionResponse) XXX_DiscardUnknown ¶
func (m *CreateConnectionResponse) XXX_DiscardUnknown()
func (*CreateConnectionResponse) XXX_Marshal ¶
func (m *CreateConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateConnectionResponse) XXX_Merge ¶
func (m *CreateConnectionResponse) XXX_Merge(src proto.Message)
func (*CreateConnectionResponse) XXX_Size ¶
func (m *CreateConnectionResponse) XXX_Size() int
func (*CreateConnectionResponse) XXX_Unmarshal ¶
func (m *CreateConnectionResponse) XXX_Unmarshal(b []byte) error
type CreateRelayRequest ¶
type CreateRelayRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` Relay *Relay `protobuf:"bytes,1,opt,name=relay,proto3" json:"relay,omitempty"` // Types that are valid to be assigned to Args: // *CreateRelayRequest_Kafka Args isCreateRelayRequest_Args `protobuf_oneof:"Args"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateRelayRequest) Descriptor ¶
func (*CreateRelayRequest) Descriptor() ([]byte, []int)
func (*CreateRelayRequest) GetArgs ¶
func (m *CreateRelayRequest) GetArgs() isCreateRelayRequest_Args
func (*CreateRelayRequest) GetAuth ¶
func (m *CreateRelayRequest) GetAuth() *common.Auth
func (*CreateRelayRequest) GetKafka ¶
func (m *CreateRelayRequest) GetKafka() *args.Kafka
func (*CreateRelayRequest) GetRelay ¶
func (m *CreateRelayRequest) GetRelay() *Relay
func (*CreateRelayRequest) ProtoMessage ¶
func (*CreateRelayRequest) ProtoMessage()
func (*CreateRelayRequest) Reset ¶
func (m *CreateRelayRequest) Reset()
func (*CreateRelayRequest) String ¶
func (m *CreateRelayRequest) String() string
func (*CreateRelayRequest) XXX_DiscardUnknown ¶
func (m *CreateRelayRequest) XXX_DiscardUnknown()
func (*CreateRelayRequest) XXX_Marshal ¶
func (m *CreateRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRelayRequest) XXX_Merge ¶
func (m *CreateRelayRequest) XXX_Merge(src proto.Message)
func (*CreateRelayRequest) XXX_OneofWrappers ¶
func (*CreateRelayRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*CreateRelayRequest) XXX_Size ¶
func (m *CreateRelayRequest) XXX_Size() int
func (*CreateRelayRequest) XXX_Unmarshal ¶
func (m *CreateRelayRequest) XXX_Unmarshal(b []byte) error
type CreateRelayResponse ¶
type CreateRelayResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` // ID of the created relay entry RelayId string `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateRelayResponse) Descriptor ¶
func (*CreateRelayResponse) Descriptor() ([]byte, []int)
func (*CreateRelayResponse) GetRelayId ¶
func (m *CreateRelayResponse) GetRelayId() string
func (*CreateRelayResponse) GetStatus ¶
func (m *CreateRelayResponse) GetStatus() *common.Status
func (*CreateRelayResponse) ProtoMessage ¶
func (*CreateRelayResponse) ProtoMessage()
func (*CreateRelayResponse) Reset ¶
func (m *CreateRelayResponse) Reset()
func (*CreateRelayResponse) String ¶
func (m *CreateRelayResponse) String() string
func (*CreateRelayResponse) XXX_DiscardUnknown ¶
func (m *CreateRelayResponse) XXX_DiscardUnknown()
func (*CreateRelayResponse) XXX_Marshal ¶
func (m *CreateRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRelayResponse) XXX_Merge ¶
func (m *CreateRelayResponse) XXX_Merge(src proto.Message)
func (*CreateRelayResponse) XXX_Size ¶
func (m *CreateRelayResponse) XXX_Size() int
func (*CreateRelayResponse) XXX_Unmarshal ¶
func (m *CreateRelayResponse) XXX_Unmarshal(b []byte) error
type DeleteConnectionRequest ¶
type DeleteConnectionRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteConnectionRequest) Descriptor ¶
func (*DeleteConnectionRequest) Descriptor() ([]byte, []int)
func (*DeleteConnectionRequest) GetAuth ¶
func (m *DeleteConnectionRequest) GetAuth() *common.Auth
func (*DeleteConnectionRequest) GetConnectionId ¶
func (m *DeleteConnectionRequest) GetConnectionId() string
func (*DeleteConnectionRequest) ProtoMessage ¶
func (*DeleteConnectionRequest) ProtoMessage()
func (*DeleteConnectionRequest) Reset ¶
func (m *DeleteConnectionRequest) Reset()
func (*DeleteConnectionRequest) String ¶
func (m *DeleteConnectionRequest) String() string
func (*DeleteConnectionRequest) XXX_DiscardUnknown ¶
func (m *DeleteConnectionRequest) XXX_DiscardUnknown()
func (*DeleteConnectionRequest) XXX_Marshal ¶
func (m *DeleteConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteConnectionRequest) XXX_Merge ¶
func (m *DeleteConnectionRequest) XXX_Merge(src proto.Message)
func (*DeleteConnectionRequest) XXX_Size ¶
func (m *DeleteConnectionRequest) XXX_Size() int
func (*DeleteConnectionRequest) XXX_Unmarshal ¶
func (m *DeleteConnectionRequest) XXX_Unmarshal(b []byte) error
type DeleteConnectionResponse ¶
type DeleteConnectionResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteConnectionResponse) Descriptor ¶
func (*DeleteConnectionResponse) Descriptor() ([]byte, []int)
func (*DeleteConnectionResponse) GetStatus ¶
func (m *DeleteConnectionResponse) GetStatus() *common.Status
func (*DeleteConnectionResponse) ProtoMessage ¶
func (*DeleteConnectionResponse) ProtoMessage()
func (*DeleteConnectionResponse) Reset ¶
func (m *DeleteConnectionResponse) Reset()
func (*DeleteConnectionResponse) String ¶
func (m *DeleteConnectionResponse) String() string
func (*DeleteConnectionResponse) XXX_DiscardUnknown ¶
func (m *DeleteConnectionResponse) XXX_DiscardUnknown()
func (*DeleteConnectionResponse) XXX_Marshal ¶
func (m *DeleteConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteConnectionResponse) XXX_Merge ¶
func (m *DeleteConnectionResponse) XXX_Merge(src proto.Message)
func (*DeleteConnectionResponse) XXX_Size ¶
func (m *DeleteConnectionResponse) XXX_Size() int
func (*DeleteConnectionResponse) XXX_Unmarshal ¶
func (m *DeleteConnectionResponse) XXX_Unmarshal(b []byte) error
type DeleteRelayRequest ¶
type DeleteRelayRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` RelayId string `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteRelayRequest) Descriptor ¶
func (*DeleteRelayRequest) Descriptor() ([]byte, []int)
func (*DeleteRelayRequest) GetAuth ¶
func (m *DeleteRelayRequest) GetAuth() *common.Auth
func (*DeleteRelayRequest) GetRelayId ¶
func (m *DeleteRelayRequest) GetRelayId() string
func (*DeleteRelayRequest) ProtoMessage ¶
func (*DeleteRelayRequest) ProtoMessage()
func (*DeleteRelayRequest) Reset ¶
func (m *DeleteRelayRequest) Reset()
func (*DeleteRelayRequest) String ¶
func (m *DeleteRelayRequest) String() string
func (*DeleteRelayRequest) XXX_DiscardUnknown ¶
func (m *DeleteRelayRequest) XXX_DiscardUnknown()
func (*DeleteRelayRequest) XXX_Marshal ¶
func (m *DeleteRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteRelayRequest) XXX_Merge ¶
func (m *DeleteRelayRequest) XXX_Merge(src proto.Message)
func (*DeleteRelayRequest) XXX_Size ¶
func (m *DeleteRelayRequest) XXX_Size() int
func (*DeleteRelayRequest) XXX_Unmarshal ¶
func (m *DeleteRelayRequest) XXX_Unmarshal(b []byte) error
type DeleteRelayResponse ¶
type DeleteRelayResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteRelayResponse) Descriptor ¶
func (*DeleteRelayResponse) Descriptor() ([]byte, []int)
func (*DeleteRelayResponse) GetStatus ¶
func (m *DeleteRelayResponse) GetStatus() *common.Status
func (*DeleteRelayResponse) ProtoMessage ¶
func (*DeleteRelayResponse) ProtoMessage()
func (*DeleteRelayResponse) Reset ¶
func (m *DeleteRelayResponse) Reset()
func (*DeleteRelayResponse) String ¶
func (m *DeleteRelayResponse) String() string
func (*DeleteRelayResponse) XXX_DiscardUnknown ¶
func (m *DeleteRelayResponse) XXX_DiscardUnknown()
func (*DeleteRelayResponse) XXX_Marshal ¶
func (m *DeleteRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteRelayResponse) XXX_Merge ¶
func (m *DeleteRelayResponse) XXX_Merge(src proto.Message)
func (*DeleteRelayResponse) XXX_Size ¶
func (m *DeleteRelayResponse) XXX_Size() int
func (*DeleteRelayResponse) XXX_Unmarshal ¶
func (m *DeleteRelayResponse) XXX_Unmarshal(b []byte) error
type GetAllConnectionsRequest ¶
type GetAllConnectionsRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetAllConnectionsRequest) Descriptor ¶
func (*GetAllConnectionsRequest) Descriptor() ([]byte, []int)
func (*GetAllConnectionsRequest) GetAuth ¶
func (m *GetAllConnectionsRequest) GetAuth() *common.Auth
func (*GetAllConnectionsRequest) ProtoMessage ¶
func (*GetAllConnectionsRequest) ProtoMessage()
func (*GetAllConnectionsRequest) Reset ¶
func (m *GetAllConnectionsRequest) Reset()
func (*GetAllConnectionsRequest) String ¶
func (m *GetAllConnectionsRequest) String() string
func (*GetAllConnectionsRequest) XXX_DiscardUnknown ¶
func (m *GetAllConnectionsRequest) XXX_DiscardUnknown()
func (*GetAllConnectionsRequest) XXX_Marshal ¶
func (m *GetAllConnectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetAllConnectionsRequest) XXX_Merge ¶
func (m *GetAllConnectionsRequest) XXX_Merge(src proto.Message)
func (*GetAllConnectionsRequest) XXX_Size ¶
func (m *GetAllConnectionsRequest) XXX_Size() int
func (*GetAllConnectionsRequest) XXX_Unmarshal ¶
func (m *GetAllConnectionsRequest) XXX_Unmarshal(b []byte) error
type GetAllConnectionsResponse ¶
type GetAllConnectionsResponse struct { Connections []*Connection `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetAllConnectionsResponse) Descriptor ¶
func (*GetAllConnectionsResponse) Descriptor() ([]byte, []int)
func (*GetAllConnectionsResponse) GetConnections ¶
func (m *GetAllConnectionsResponse) GetConnections() []*Connection
func (*GetAllConnectionsResponse) ProtoMessage ¶
func (*GetAllConnectionsResponse) ProtoMessage()
func (*GetAllConnectionsResponse) Reset ¶
func (m *GetAllConnectionsResponse) Reset()
func (*GetAllConnectionsResponse) String ¶
func (m *GetAllConnectionsResponse) String() string
func (*GetAllConnectionsResponse) XXX_DiscardUnknown ¶
func (m *GetAllConnectionsResponse) XXX_DiscardUnknown()
func (*GetAllConnectionsResponse) XXX_Marshal ¶
func (m *GetAllConnectionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetAllConnectionsResponse) XXX_Merge ¶
func (m *GetAllConnectionsResponse) XXX_Merge(src proto.Message)
func (*GetAllConnectionsResponse) XXX_Size ¶
func (m *GetAllConnectionsResponse) XXX_Size() int
func (*GetAllConnectionsResponse) XXX_Unmarshal ¶
func (m *GetAllConnectionsResponse) XXX_Unmarshal(b []byte) error
type GetAllRelaysRequest ¶
type GetAllRelaysRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetAllRelaysRequest) Descriptor ¶
func (*GetAllRelaysRequest) Descriptor() ([]byte, []int)
func (*GetAllRelaysRequest) GetAuth ¶
func (m *GetAllRelaysRequest) GetAuth() *common.Auth
func (*GetAllRelaysRequest) ProtoMessage ¶
func (*GetAllRelaysRequest) ProtoMessage()
func (*GetAllRelaysRequest) Reset ¶
func (m *GetAllRelaysRequest) Reset()
func (*GetAllRelaysRequest) String ¶
func (m *GetAllRelaysRequest) String() string
func (*GetAllRelaysRequest) XXX_DiscardUnknown ¶
func (m *GetAllRelaysRequest) XXX_DiscardUnknown()
func (*GetAllRelaysRequest) XXX_Marshal ¶
func (m *GetAllRelaysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetAllRelaysRequest) XXX_Merge ¶
func (m *GetAllRelaysRequest) XXX_Merge(src proto.Message)
func (*GetAllRelaysRequest) XXX_Size ¶
func (m *GetAllRelaysRequest) XXX_Size() int
func (*GetAllRelaysRequest) XXX_Unmarshal ¶
func (m *GetAllRelaysRequest) XXX_Unmarshal(b []byte) error
type GetAllRelaysResponse ¶
type GetAllRelaysResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` // Will be set as empty []Relay if no relays are configured Relays []*Relay `protobuf:"bytes,1,rep,name=relays,proto3" json:"relays,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetAllRelaysResponse) Descriptor ¶
func (*GetAllRelaysResponse) Descriptor() ([]byte, []int)
func (*GetAllRelaysResponse) GetRelays ¶
func (m *GetAllRelaysResponse) GetRelays() []*Relay
func (*GetAllRelaysResponse) GetStatus ¶
func (m *GetAllRelaysResponse) GetStatus() *common.Status
func (*GetAllRelaysResponse) ProtoMessage ¶
func (*GetAllRelaysResponse) ProtoMessage()
func (*GetAllRelaysResponse) Reset ¶
func (m *GetAllRelaysResponse) Reset()
func (*GetAllRelaysResponse) String ¶
func (m *GetAllRelaysResponse) String() string
func (*GetAllRelaysResponse) XXX_DiscardUnknown ¶
func (m *GetAllRelaysResponse) XXX_DiscardUnknown()
func (*GetAllRelaysResponse) XXX_Marshal ¶
func (m *GetAllRelaysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetAllRelaysResponse) XXX_Merge ¶
func (m *GetAllRelaysResponse) XXX_Merge(src proto.Message)
func (*GetAllRelaysResponse) XXX_Size ¶
func (m *GetAllRelaysResponse) XXX_Size() int
func (*GetAllRelaysResponse) XXX_Unmarshal ¶
func (m *GetAllRelaysResponse) XXX_Unmarshal(b []byte) error
type GetConnectionRequest ¶
type GetConnectionRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetConnectionRequest) Descriptor ¶
func (*GetConnectionRequest) Descriptor() ([]byte, []int)
func (*GetConnectionRequest) GetAuth ¶
func (m *GetConnectionRequest) GetAuth() *common.Auth
func (*GetConnectionRequest) GetConnectionId ¶
func (m *GetConnectionRequest) GetConnectionId() string
func (*GetConnectionRequest) ProtoMessage ¶
func (*GetConnectionRequest) ProtoMessage()
func (*GetConnectionRequest) Reset ¶
func (m *GetConnectionRequest) Reset()
func (*GetConnectionRequest) String ¶
func (m *GetConnectionRequest) String() string
func (*GetConnectionRequest) XXX_DiscardUnknown ¶
func (m *GetConnectionRequest) XXX_DiscardUnknown()
func (*GetConnectionRequest) XXX_Marshal ¶
func (m *GetConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetConnectionRequest) XXX_Merge ¶
func (m *GetConnectionRequest) XXX_Merge(src proto.Message)
func (*GetConnectionRequest) XXX_Size ¶
func (m *GetConnectionRequest) XXX_Size() int
func (*GetConnectionRequest) XXX_Unmarshal ¶
func (m *GetConnectionRequest) XXX_Unmarshal(b []byte) error
type GetConnectionResponse ¶
type GetConnectionResponse struct { Connection *Connection `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetConnectionResponse) Descriptor ¶
func (*GetConnectionResponse) Descriptor() ([]byte, []int)
func (*GetConnectionResponse) GetConnection ¶
func (m *GetConnectionResponse) GetConnection() *Connection
func (*GetConnectionResponse) ProtoMessage ¶
func (*GetConnectionResponse) ProtoMessage()
func (*GetConnectionResponse) Reset ¶
func (m *GetConnectionResponse) Reset()
func (*GetConnectionResponse) String ¶
func (m *GetConnectionResponse) String() string
func (*GetConnectionResponse) XXX_DiscardUnknown ¶
func (m *GetConnectionResponse) XXX_DiscardUnknown()
func (*GetConnectionResponse) XXX_Marshal ¶
func (m *GetConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetConnectionResponse) XXX_Merge ¶
func (m *GetConnectionResponse) XXX_Merge(src proto.Message)
func (*GetConnectionResponse) XXX_Size ¶
func (m *GetConnectionResponse) XXX_Size() int
func (*GetConnectionResponse) XXX_Unmarshal ¶
func (m *GetConnectionResponse) XXX_Unmarshal(b []byte) error
type GetRelayRequest ¶
type GetRelayRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` RelayId string `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRelayRequest) Descriptor ¶
func (*GetRelayRequest) Descriptor() ([]byte, []int)
func (*GetRelayRequest) GetAuth ¶
func (m *GetRelayRequest) GetAuth() *common.Auth
func (*GetRelayRequest) GetRelayId ¶
func (m *GetRelayRequest) GetRelayId() string
func (*GetRelayRequest) ProtoMessage ¶
func (*GetRelayRequest) ProtoMessage()
func (*GetRelayRequest) Reset ¶
func (m *GetRelayRequest) Reset()
func (*GetRelayRequest) String ¶
func (m *GetRelayRequest) String() string
func (*GetRelayRequest) XXX_DiscardUnknown ¶
func (m *GetRelayRequest) XXX_DiscardUnknown()
func (*GetRelayRequest) XXX_Marshal ¶
func (m *GetRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRelayRequest) XXX_Merge ¶
func (m *GetRelayRequest) XXX_Merge(src proto.Message)
func (*GetRelayRequest) XXX_Size ¶
func (m *GetRelayRequest) XXX_Size() int
func (*GetRelayRequest) XXX_Unmarshal ¶
func (m *GetRelayRequest) XXX_Unmarshal(b []byte) error
type GetRelayResponse ¶
type GetRelayResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` // Set only if status is OK Relay *Relay `protobuf:"bytes,1,opt,name=relay,proto3" json:"relay,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRelayResponse) Descriptor ¶
func (*GetRelayResponse) Descriptor() ([]byte, []int)
func (*GetRelayResponse) GetRelay ¶
func (m *GetRelayResponse) GetRelay() *Relay
func (*GetRelayResponse) GetStatus ¶
func (m *GetRelayResponse) GetStatus() *common.Status
func (*GetRelayResponse) ProtoMessage ¶
func (*GetRelayResponse) ProtoMessage()
func (*GetRelayResponse) Reset ¶
func (m *GetRelayResponse) Reset()
func (*GetRelayResponse) String ¶
func (m *GetRelayResponse) String() string
func (*GetRelayResponse) XXX_DiscardUnknown ¶
func (m *GetRelayResponse) XXX_DiscardUnknown()
func (*GetRelayResponse) XXX_Marshal ¶
func (m *GetRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRelayResponse) XXX_Merge ¶
func (m *GetRelayResponse) XXX_Merge(src proto.Message)
func (*GetRelayResponse) XXX_Size ¶
func (m *GetRelayResponse) XXX_Size() int
func (*GetRelayResponse) XXX_Unmarshal ¶
func (m *GetRelayResponse) XXX_Unmarshal(b []byte) error
type PlumberServerClient ¶
type PlumberServerClient interface { // List configured/known connections GetAllConnections(ctx context.Context, in *GetAllConnectionsRequest, opts ...grpc.CallOption) (*GetAllConnectionsResponse, error) // Fetch a specific connection by ID GetConnection(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*GetConnectionResponse, error) // Create a connection in plumber CreateConnection(ctx context.Context, in *CreateConnectionRequest, opts ...grpc.CallOption) (*CreateConnectionResponse, error) // Test a connection before saving its configuration TestConnection(ctx context.Context, in *TestConnectionRequest, opts ...grpc.CallOption) (*TestConnectionResponse, error) // Any active connections will be restarted UpdateConnection(ctx context.Context, in *UpdateConnectionRequest, opts ...grpc.CallOption) (*UpdateConnectionResponse, error) // If there are any active connections, delete will cause them to get closed DeleteConnection(ctx context.Context, in *DeleteConnectionRequest, opts ...grpc.CallOption) (*DeleteConnectionResponse, error) // Start reading data from a connection StartRead(ctx context.Context, in *StartReadRequest, opts ...grpc.CallOption) (PlumberServer_StartReadClient, error) // Stop reading data from a connection StopRead(ctx context.Context, in *StopReadRequest, opts ...grpc.CallOption) (*StopReadResponse, error) // Write data to a connection Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error) // Create a data relay from plumber server to the Batch platform CreateRelay(ctx context.Context, in *CreateRelayRequest, opts ...grpc.CallOption) (*CreateRelayResponse, error) // Update a relay (such as API token) - relay will be interrupted! UpdateRelay(ctx context.Context, in *UpdateRelayRequest, opts ...grpc.CallOption) (*UpdateRelayResponse, error) StopRelay(ctx context.Context, in *StopRelayRequest, opts ...grpc.CallOption) (*StopRelayResponse, error) // Delete an existing relay DeleteRelay(ctx context.Context, in *DeleteRelayRequest, opts ...grpc.CallOption) (*DeleteRelayResponse, error) }
PlumberServerClient is the client API for PlumberServer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPlumberServerClient ¶
func NewPlumberServerClient(cc *grpc.ClientConn) PlumberServerClient
type PlumberServerServer ¶
type PlumberServerServer interface { // List configured/known connections GetAllConnections(context.Context, *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error) // Fetch a specific connection by ID GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error) // Create a connection in plumber CreateConnection(context.Context, *CreateConnectionRequest) (*CreateConnectionResponse, error) // Test a connection before saving its configuration TestConnection(context.Context, *TestConnectionRequest) (*TestConnectionResponse, error) // Any active connections will be restarted UpdateConnection(context.Context, *UpdateConnectionRequest) (*UpdateConnectionResponse, error) // If there are any active connections, delete will cause them to get closed DeleteConnection(context.Context, *DeleteConnectionRequest) (*DeleteConnectionResponse, error) // Start reading data from a connection StartRead(*StartReadRequest, PlumberServer_StartReadServer) error // Stop reading data from a connection StopRead(context.Context, *StopReadRequest) (*StopReadResponse, error) // Write data to a connection Write(context.Context, *WriteRequest) (*WriteResponse, error) // Create a data relay from plumber server to the Batch platform CreateRelay(context.Context, *CreateRelayRequest) (*CreateRelayResponse, error) // Update a relay (such as API token) - relay will be interrupted! UpdateRelay(context.Context, *UpdateRelayRequest) (*UpdateRelayResponse, error) StopRelay(context.Context, *StopRelayRequest) (*StopRelayResponse, error) // Delete an existing relay DeleteRelay(context.Context, *DeleteRelayRequest) (*DeleteRelayResponse, error) }
PlumberServerServer is the server API for PlumberServer service.
type PlumberServer_StartReadClient ¶
type PlumberServer_StartReadClient interface { Recv() (*StartReadResponse, error) grpc.ClientStream }
type PlumberServer_StartReadServer ¶
type PlumberServer_StartReadServer interface { Send(*StartReadResponse) error grpc.ServerStream }
type ReadOptions ¶
type ReadOptions struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReadOptions) Descriptor ¶
func (*ReadOptions) Descriptor() ([]byte, []int)
func (*ReadOptions) ProtoMessage ¶
func (*ReadOptions) ProtoMessage()
func (*ReadOptions) Reset ¶
func (m *ReadOptions) Reset()
func (*ReadOptions) String ¶
func (m *ReadOptions) String() string
func (*ReadOptions) XXX_DiscardUnknown ¶
func (m *ReadOptions) XXX_DiscardUnknown()
func (*ReadOptions) XXX_Marshal ¶
func (m *ReadOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadOptions) XXX_Merge ¶
func (m *ReadOptions) XXX_Merge(src proto.Message)
func (*ReadOptions) XXX_Size ¶
func (m *ReadOptions) XXX_Size() int
func (*ReadOptions) XXX_Unmarshal ¶
func (m *ReadOptions) XXX_Unmarshal(b []byte) error
type ReadOptions_Type ¶
type ReadOptions_Type int32
const ( ReadOptions_ONE_TIME ReadOptions_Type = 0 ReadOptions_CONTINUOUS ReadOptions_Type = 1 )
func (ReadOptions_Type) EnumDescriptor ¶
func (ReadOptions_Type) EnumDescriptor() ([]byte, []int)
func (ReadOptions_Type) String ¶
func (x ReadOptions_Type) String() string
type Relay ¶
type Relay struct { // Required BatchCollectionToken string `protobuf:"bytes,1,opt,name=batch_collection_token,json=batchCollectionToken,proto3" json:"batch_collection_token,omitempty"` // Optional; how many messages to send in a single batch (default: 1000) BatchSize int32 `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"` // Optional; how many times plumber will try re-sending a batch (default: 3) BatchMaxRetry int32 `protobuf:"varint,3,opt,name=batch_max_retry,json=batchMaxRetry,proto3" json:"batch_max_retry,omitempty"` ConnectionId string `protobuf:"bytes,4,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` // Optional; where to send events to (default: grpc-collector.batch.sh:9000) BatchshGrpcAddress string `protobuf:"bytes,5,opt,name=batchsh_grpc_address,json=batchshGrpcAddress,proto3" json:"batchsh_grpc_address,omitempty"` // Optional; whether to use TLS for gRPC (default: true) BatchshGrpcDisableTls bool `` /* 129-byte string literal not displayed */ // Optional: how long to wait before giving up talking to the gRPC collector (default: 10s) BatchshGrpcTimeout bool `protobuf:"varint,7,opt,name=batchsh_grpc_timeout,json=batchshGrpcTimeout,proto3" json:"batchsh_grpc_timeout,omitempty"` // Set appropriate args based on what connection is specified // ie. If connection_id is for kafka - specify Kafka args // // Types that are valid to be assigned to Args: // *Relay_Kafka Args isRelay_Args `protobuf_oneof:"Args"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Relay) Descriptor ¶
func (*Relay) GetBatchCollectionToken ¶
func (*Relay) GetBatchMaxRetry ¶
func (*Relay) GetBatchSize ¶
func (*Relay) GetBatchshGrpcAddress ¶
func (*Relay) GetBatchshGrpcDisableTls ¶
func (*Relay) GetBatchshGrpcTimeout ¶
func (*Relay) GetConnectionId ¶
func (*Relay) ProtoMessage ¶
func (*Relay) ProtoMessage()
func (*Relay) XXX_DiscardUnknown ¶
func (m *Relay) XXX_DiscardUnknown()
func (*Relay) XXX_Marshal ¶
func (*Relay) XXX_OneofWrappers ¶
func (*Relay) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Relay) XXX_Unmarshal ¶
type Relay_Kafka ¶
type SampleOptions ¶
type SampleOptions struct { SampleRate uint32 `protobuf:"varint,1,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"` SampleInterval SampleOptions_Interval `` /* 139-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SampleOptions) Descriptor ¶
func (*SampleOptions) Descriptor() ([]byte, []int)
func (*SampleOptions) GetSampleInterval ¶
func (m *SampleOptions) GetSampleInterval() SampleOptions_Interval
func (*SampleOptions) GetSampleRate ¶
func (m *SampleOptions) GetSampleRate() uint32
func (*SampleOptions) ProtoMessage ¶
func (*SampleOptions) ProtoMessage()
func (*SampleOptions) Reset ¶
func (m *SampleOptions) Reset()
func (*SampleOptions) String ¶
func (m *SampleOptions) String() string
func (*SampleOptions) XXX_DiscardUnknown ¶
func (m *SampleOptions) XXX_DiscardUnknown()
func (*SampleOptions) XXX_Marshal ¶
func (m *SampleOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SampleOptions) XXX_Merge ¶
func (m *SampleOptions) XXX_Merge(src proto.Message)
func (*SampleOptions) XXX_Size ¶
func (m *SampleOptions) XXX_Size() int
func (*SampleOptions) XXX_Unmarshal ¶
func (m *SampleOptions) XXX_Unmarshal(b []byte) error
type SampleOptions_Interval ¶
type SampleOptions_Interval int32
const ( SampleOptions_SECOND SampleOptions_Interval = 0 SampleOptions_MINUTE SampleOptions_Interval = 1 SampleOptions_HOUR SampleOptions_Interval = 2 )
func (SampleOptions_Interval) EnumDescriptor ¶
func (SampleOptions_Interval) EnumDescriptor() ([]byte, []int)
func (SampleOptions_Interval) String ¶
func (x SampleOptions_Interval) String() string
type StartReadRequest ¶
type StartReadRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` ReadOptions *ReadOptions `protobuf:"bytes,2,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"` SampleOptions *SampleOptions `protobuf:"bytes,3,opt,name=sample_options,json=sampleOptions,proto3" json:"sample_options,omitempty"` DecodeOptions *encoding.Options `protobuf:"bytes,4,opt,name=decode_options,json=decodeOptions,proto3" json:"decode_options,omitempty"` // Types that are valid to be assigned to Args: // *StartReadRequest_Kafka Args isStartReadRequest_Args `protobuf_oneof:"Args"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartReadRequest) Descriptor ¶
func (*StartReadRequest) Descriptor() ([]byte, []int)
func (*StartReadRequest) GetArgs ¶
func (m *StartReadRequest) GetArgs() isStartReadRequest_Args
func (*StartReadRequest) GetAuth ¶
func (m *StartReadRequest) GetAuth() *common.Auth
func (*StartReadRequest) GetConnectionId ¶
func (m *StartReadRequest) GetConnectionId() string
func (*StartReadRequest) GetDecodeOptions ¶
func (m *StartReadRequest) GetDecodeOptions() *encoding.Options
func (*StartReadRequest) GetKafka ¶
func (m *StartReadRequest) GetKafka() *args.Kafka
func (*StartReadRequest) GetReadOptions ¶
func (m *StartReadRequest) GetReadOptions() *ReadOptions
func (*StartReadRequest) GetSampleOptions ¶
func (m *StartReadRequest) GetSampleOptions() *SampleOptions
func (*StartReadRequest) ProtoMessage ¶
func (*StartReadRequest) ProtoMessage()
func (*StartReadRequest) Reset ¶
func (m *StartReadRequest) Reset()
func (*StartReadRequest) String ¶
func (m *StartReadRequest) String() string
func (*StartReadRequest) XXX_DiscardUnknown ¶
func (m *StartReadRequest) XXX_DiscardUnknown()
func (*StartReadRequest) XXX_Marshal ¶
func (m *StartReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartReadRequest) XXX_Merge ¶
func (m *StartReadRequest) XXX_Merge(src proto.Message)
func (*StartReadRequest) XXX_OneofWrappers ¶
func (*StartReadRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*StartReadRequest) XXX_Size ¶
func (m *StartReadRequest) XXX_Size() int
func (*StartReadRequest) XXX_Unmarshal ¶
func (m *StartReadRequest) XXX_Unmarshal(b []byte) error
type StartReadRequest_Kafka ¶
type StartReadResponse ¶
type StartReadResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` // Assigned and returned by plumber-server to identify a successful read request ReadId string `protobuf:"bytes,1,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"` Messages []*records.Message `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartReadResponse) Descriptor ¶
func (*StartReadResponse) Descriptor() ([]byte, []int)
func (*StartReadResponse) GetMessages ¶
func (m *StartReadResponse) GetMessages() []*records.Message
func (*StartReadResponse) GetReadId ¶
func (m *StartReadResponse) GetReadId() string
func (*StartReadResponse) GetStatus ¶
func (m *StartReadResponse) GetStatus() *common.Status
func (*StartReadResponse) ProtoMessage ¶
func (*StartReadResponse) ProtoMessage()
func (*StartReadResponse) Reset ¶
func (m *StartReadResponse) Reset()
func (*StartReadResponse) String ¶
func (m *StartReadResponse) String() string
func (*StartReadResponse) XXX_DiscardUnknown ¶
func (m *StartReadResponse) XXX_DiscardUnknown()
func (*StartReadResponse) XXX_Marshal ¶
func (m *StartReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartReadResponse) XXX_Merge ¶
func (m *StartReadResponse) XXX_Merge(src proto.Message)
func (*StartReadResponse) XXX_Size ¶
func (m *StartReadResponse) XXX_Size() int
func (*StartReadResponse) XXX_Unmarshal ¶
func (m *StartReadResponse) XXX_Unmarshal(b []byte) error
type StopReadRequest ¶
type StopReadRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` ReadId string `protobuf:"bytes,1,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StopReadRequest) Descriptor ¶
func (*StopReadRequest) Descriptor() ([]byte, []int)
func (*StopReadRequest) GetAuth ¶
func (m *StopReadRequest) GetAuth() *common.Auth
func (*StopReadRequest) GetReadId ¶
func (m *StopReadRequest) GetReadId() string
func (*StopReadRequest) ProtoMessage ¶
func (*StopReadRequest) ProtoMessage()
func (*StopReadRequest) Reset ¶
func (m *StopReadRequest) Reset()
func (*StopReadRequest) String ¶
func (m *StopReadRequest) String() string
func (*StopReadRequest) XXX_DiscardUnknown ¶
func (m *StopReadRequest) XXX_DiscardUnknown()
func (*StopReadRequest) XXX_Marshal ¶
func (m *StopReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopReadRequest) XXX_Merge ¶
func (m *StopReadRequest) XXX_Merge(src proto.Message)
func (*StopReadRequest) XXX_Size ¶
func (m *StopReadRequest) XXX_Size() int
func (*StopReadRequest) XXX_Unmarshal ¶
func (m *StopReadRequest) XXX_Unmarshal(b []byte) error
type StopReadResponse ¶
type StopReadResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StopReadResponse) Descriptor ¶
func (*StopReadResponse) Descriptor() ([]byte, []int)
func (*StopReadResponse) GetStatus ¶
func (m *StopReadResponse) GetStatus() *common.Status
func (*StopReadResponse) ProtoMessage ¶
func (*StopReadResponse) ProtoMessage()
func (*StopReadResponse) Reset ¶
func (m *StopReadResponse) Reset()
func (*StopReadResponse) String ¶
func (m *StopReadResponse) String() string
func (*StopReadResponse) XXX_DiscardUnknown ¶
func (m *StopReadResponse) XXX_DiscardUnknown()
func (*StopReadResponse) XXX_Marshal ¶
func (m *StopReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopReadResponse) XXX_Merge ¶
func (m *StopReadResponse) XXX_Merge(src proto.Message)
func (*StopReadResponse) XXX_Size ¶
func (m *StopReadResponse) XXX_Size() int
func (*StopReadResponse) XXX_Unmarshal ¶
func (m *StopReadResponse) XXX_Unmarshal(b []byte) error
type StopRelayRequest ¶
type StopRelayRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` RelayId string `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Temporarily stop/pause a relay
func (*StopRelayRequest) Descriptor ¶
func (*StopRelayRequest) Descriptor() ([]byte, []int)
func (*StopRelayRequest) GetAuth ¶
func (m *StopRelayRequest) GetAuth() *common.Auth
func (*StopRelayRequest) GetRelayId ¶
func (m *StopRelayRequest) GetRelayId() string
func (*StopRelayRequest) ProtoMessage ¶
func (*StopRelayRequest) ProtoMessage()
func (*StopRelayRequest) Reset ¶
func (m *StopRelayRequest) Reset()
func (*StopRelayRequest) String ¶
func (m *StopRelayRequest) String() string
func (*StopRelayRequest) XXX_DiscardUnknown ¶
func (m *StopRelayRequest) XXX_DiscardUnknown()
func (*StopRelayRequest) XXX_Marshal ¶
func (m *StopRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopRelayRequest) XXX_Merge ¶
func (m *StopRelayRequest) XXX_Merge(src proto.Message)
func (*StopRelayRequest) XXX_Size ¶
func (m *StopRelayRequest) XXX_Size() int
func (*StopRelayRequest) XXX_Unmarshal ¶
func (m *StopRelayRequest) XXX_Unmarshal(b []byte) error
type StopRelayResponse ¶
type StopRelayResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StopRelayResponse) Descriptor ¶
func (*StopRelayResponse) Descriptor() ([]byte, []int)
func (*StopRelayResponse) GetStatus ¶
func (m *StopRelayResponse) GetStatus() *common.Status
func (*StopRelayResponse) ProtoMessage ¶
func (*StopRelayResponse) ProtoMessage()
func (*StopRelayResponse) Reset ¶
func (m *StopRelayResponse) Reset()
func (*StopRelayResponse) String ¶
func (m *StopRelayResponse) String() string
func (*StopRelayResponse) XXX_DiscardUnknown ¶
func (m *StopRelayResponse) XXX_DiscardUnknown()
func (*StopRelayResponse) XXX_Marshal ¶
func (m *StopRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopRelayResponse) XXX_Merge ¶
func (m *StopRelayResponse) XXX_Merge(src proto.Message)
func (*StopRelayResponse) XXX_Size ¶
func (m *StopRelayResponse) XXX_Size() int
func (*StopRelayResponse) XXX_Unmarshal ¶
func (m *StopRelayResponse) XXX_Unmarshal(b []byte) error
type TestConnectionRequest ¶
type TestConnectionRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` Connection *Connection `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TestConnectionRequest) Descriptor ¶
func (*TestConnectionRequest) Descriptor() ([]byte, []int)
func (*TestConnectionRequest) GetAuth ¶
func (m *TestConnectionRequest) GetAuth() *common.Auth
func (*TestConnectionRequest) GetConnection ¶
func (m *TestConnectionRequest) GetConnection() *Connection
func (*TestConnectionRequest) ProtoMessage ¶
func (*TestConnectionRequest) ProtoMessage()
func (*TestConnectionRequest) Reset ¶
func (m *TestConnectionRequest) Reset()
func (*TestConnectionRequest) String ¶
func (m *TestConnectionRequest) String() string
func (*TestConnectionRequest) XXX_DiscardUnknown ¶
func (m *TestConnectionRequest) XXX_DiscardUnknown()
func (*TestConnectionRequest) XXX_Marshal ¶
func (m *TestConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestConnectionRequest) XXX_Merge ¶
func (m *TestConnectionRequest) XXX_Merge(src proto.Message)
func (*TestConnectionRequest) XXX_Size ¶
func (m *TestConnectionRequest) XXX_Size() int
func (*TestConnectionRequest) XXX_Unmarshal ¶
func (m *TestConnectionRequest) XXX_Unmarshal(b []byte) error
type TestConnectionResponse ¶
type TestConnectionResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TestConnectionResponse) Descriptor ¶
func (*TestConnectionResponse) Descriptor() ([]byte, []int)
func (*TestConnectionResponse) GetStatus ¶
func (m *TestConnectionResponse) GetStatus() *common.Status
func (*TestConnectionResponse) ProtoMessage ¶
func (*TestConnectionResponse) ProtoMessage()
func (*TestConnectionResponse) Reset ¶
func (m *TestConnectionResponse) Reset()
func (*TestConnectionResponse) String ¶
func (m *TestConnectionResponse) String() string
func (*TestConnectionResponse) XXX_DiscardUnknown ¶
func (m *TestConnectionResponse) XXX_DiscardUnknown()
func (*TestConnectionResponse) XXX_Marshal ¶
func (m *TestConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestConnectionResponse) XXX_Merge ¶
func (m *TestConnectionResponse) XXX_Merge(src proto.Message)
func (*TestConnectionResponse) XXX_Size ¶
func (m *TestConnectionResponse) XXX_Size() int
func (*TestConnectionResponse) XXX_Unmarshal ¶
func (m *TestConnectionResponse) XXX_Unmarshal(b []byte) error
type UnimplementedPlumberServerServer ¶
type UnimplementedPlumberServerServer struct { }
UnimplementedPlumberServerServer can be embedded to have forward compatible implementations.
func (*UnimplementedPlumberServerServer) CreateConnection ¶
func (*UnimplementedPlumberServerServer) CreateConnection(ctx context.Context, req *CreateConnectionRequest) (*CreateConnectionResponse, error)
func (*UnimplementedPlumberServerServer) CreateRelay ¶
func (*UnimplementedPlumberServerServer) CreateRelay(ctx context.Context, req *CreateRelayRequest) (*CreateRelayResponse, error)
func (*UnimplementedPlumberServerServer) DeleteConnection ¶
func (*UnimplementedPlumberServerServer) DeleteConnection(ctx context.Context, req *DeleteConnectionRequest) (*DeleteConnectionResponse, error)
func (*UnimplementedPlumberServerServer) DeleteRelay ¶
func (*UnimplementedPlumberServerServer) DeleteRelay(ctx context.Context, req *DeleteRelayRequest) (*DeleteRelayResponse, error)
func (*UnimplementedPlumberServerServer) GetAllConnections ¶
func (*UnimplementedPlumberServerServer) GetAllConnections(ctx context.Context, req *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error)
func (*UnimplementedPlumberServerServer) GetConnection ¶ added in v0.0.3
func (*UnimplementedPlumberServerServer) GetConnection(ctx context.Context, req *GetConnectionRequest) (*GetConnectionResponse, error)
func (*UnimplementedPlumberServerServer) StartRead ¶
func (*UnimplementedPlumberServerServer) StartRead(req *StartReadRequest, srv PlumberServer_StartReadServer) error
func (*UnimplementedPlumberServerServer) StopRead ¶
func (*UnimplementedPlumberServerServer) StopRead(ctx context.Context, req *StopReadRequest) (*StopReadResponse, error)
func (*UnimplementedPlumberServerServer) StopRelay ¶
func (*UnimplementedPlumberServerServer) StopRelay(ctx context.Context, req *StopRelayRequest) (*StopRelayResponse, error)
func (*UnimplementedPlumberServerServer) TestConnection ¶
func (*UnimplementedPlumberServerServer) TestConnection(ctx context.Context, req *TestConnectionRequest) (*TestConnectionResponse, error)
func (*UnimplementedPlumberServerServer) UpdateConnection ¶
func (*UnimplementedPlumberServerServer) UpdateConnection(ctx context.Context, req *UpdateConnectionRequest) (*UpdateConnectionResponse, error)
func (*UnimplementedPlumberServerServer) UpdateRelay ¶
func (*UnimplementedPlumberServerServer) UpdateRelay(ctx context.Context, req *UpdateRelayRequest) (*UpdateRelayResponse, error)
func (*UnimplementedPlumberServerServer) Write ¶
func (*UnimplementedPlumberServerServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)
type UpdateConnectionRequest ¶
type UpdateConnectionRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateConnectionRequest) Descriptor ¶
func (*UpdateConnectionRequest) Descriptor() ([]byte, []int)
func (*UpdateConnectionRequest) GetAuth ¶
func (m *UpdateConnectionRequest) GetAuth() *common.Auth
func (*UpdateConnectionRequest) GetConnection ¶
func (m *UpdateConnectionRequest) GetConnection() *Connection
func (*UpdateConnectionRequest) GetConnectionId ¶
func (m *UpdateConnectionRequest) GetConnectionId() string
func (*UpdateConnectionRequest) ProtoMessage ¶
func (*UpdateConnectionRequest) ProtoMessage()
func (*UpdateConnectionRequest) Reset ¶
func (m *UpdateConnectionRequest) Reset()
func (*UpdateConnectionRequest) String ¶
func (m *UpdateConnectionRequest) String() string
func (*UpdateConnectionRequest) XXX_DiscardUnknown ¶
func (m *UpdateConnectionRequest) XXX_DiscardUnknown()
func (*UpdateConnectionRequest) XXX_Marshal ¶
func (m *UpdateConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateConnectionRequest) XXX_Merge ¶
func (m *UpdateConnectionRequest) XXX_Merge(src proto.Message)
func (*UpdateConnectionRequest) XXX_Size ¶
func (m *UpdateConnectionRequest) XXX_Size() int
func (*UpdateConnectionRequest) XXX_Unmarshal ¶
func (m *UpdateConnectionRequest) XXX_Unmarshal(b []byte) error
type UpdateConnectionResponse ¶
type UpdateConnectionResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateConnectionResponse) Descriptor ¶
func (*UpdateConnectionResponse) Descriptor() ([]byte, []int)
func (*UpdateConnectionResponse) GetStatus ¶
func (m *UpdateConnectionResponse) GetStatus() *common.Status
func (*UpdateConnectionResponse) ProtoMessage ¶
func (*UpdateConnectionResponse) ProtoMessage()
func (*UpdateConnectionResponse) Reset ¶
func (m *UpdateConnectionResponse) Reset()
func (*UpdateConnectionResponse) String ¶
func (m *UpdateConnectionResponse) String() string
func (*UpdateConnectionResponse) XXX_DiscardUnknown ¶
func (m *UpdateConnectionResponse) XXX_DiscardUnknown()
func (*UpdateConnectionResponse) XXX_Marshal ¶
func (m *UpdateConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateConnectionResponse) XXX_Merge ¶
func (m *UpdateConnectionResponse) XXX_Merge(src proto.Message)
func (*UpdateConnectionResponse) XXX_Size ¶
func (m *UpdateConnectionResponse) XXX_Size() int
func (*UpdateConnectionResponse) XXX_Unmarshal ¶
func (m *UpdateConnectionResponse) XXX_Unmarshal(b []byte) error
type UpdateRelayRequest ¶
type UpdateRelayRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` RelayId string `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"` Relay *Relay `protobuf:"bytes,2,opt,name=relay,proto3" json:"relay,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
WARNING: Any in-progress relay will be interrupted/restarted
func (*UpdateRelayRequest) Descriptor ¶
func (*UpdateRelayRequest) Descriptor() ([]byte, []int)
func (*UpdateRelayRequest) GetAuth ¶
func (m *UpdateRelayRequest) GetAuth() *common.Auth
func (*UpdateRelayRequest) GetRelay ¶
func (m *UpdateRelayRequest) GetRelay() *Relay
func (*UpdateRelayRequest) GetRelayId ¶
func (m *UpdateRelayRequest) GetRelayId() string
func (*UpdateRelayRequest) ProtoMessage ¶
func (*UpdateRelayRequest) ProtoMessage()
func (*UpdateRelayRequest) Reset ¶
func (m *UpdateRelayRequest) Reset()
func (*UpdateRelayRequest) String ¶
func (m *UpdateRelayRequest) String() string
func (*UpdateRelayRequest) XXX_DiscardUnknown ¶
func (m *UpdateRelayRequest) XXX_DiscardUnknown()
func (*UpdateRelayRequest) XXX_Marshal ¶
func (m *UpdateRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateRelayRequest) XXX_Merge ¶
func (m *UpdateRelayRequest) XXX_Merge(src proto.Message)
func (*UpdateRelayRequest) XXX_Size ¶
func (m *UpdateRelayRequest) XXX_Size() int
func (*UpdateRelayRequest) XXX_Unmarshal ¶
func (m *UpdateRelayRequest) XXX_Unmarshal(b []byte) error
type UpdateRelayResponse ¶
type UpdateRelayResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateRelayResponse) Descriptor ¶
func (*UpdateRelayResponse) Descriptor() ([]byte, []int)
func (*UpdateRelayResponse) GetStatus ¶
func (m *UpdateRelayResponse) GetStatus() *common.Status
func (*UpdateRelayResponse) ProtoMessage ¶
func (*UpdateRelayResponse) ProtoMessage()
func (*UpdateRelayResponse) Reset ¶
func (m *UpdateRelayResponse) Reset()
func (*UpdateRelayResponse) String ¶
func (m *UpdateRelayResponse) String() string
func (*UpdateRelayResponse) XXX_DiscardUnknown ¶
func (m *UpdateRelayResponse) XXX_DiscardUnknown()
func (*UpdateRelayResponse) XXX_Marshal ¶
func (m *UpdateRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateRelayResponse) XXX_Merge ¶
func (m *UpdateRelayResponse) XXX_Merge(src proto.Message)
func (*UpdateRelayResponse) XXX_Size ¶
func (m *UpdateRelayResponse) XXX_Size() int
func (*UpdateRelayResponse) XXX_Unmarshal ¶
func (m *UpdateRelayResponse) XXX_Unmarshal(b []byte) error
type WriteRecord ¶
type WriteRecord struct { // Types that are valid to be assigned to Records: // *WriteRecord_Kafka Records isWriteRecord_Records `protobuf_oneof:"Records"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WriteRecord) Descriptor ¶
func (*WriteRecord) Descriptor() ([]byte, []int)
func (*WriteRecord) GetKafka ¶
func (m *WriteRecord) GetKafka() *records.Kafka
func (*WriteRecord) GetRecords ¶
func (m *WriteRecord) GetRecords() isWriteRecord_Records
func (*WriteRecord) ProtoMessage ¶
func (*WriteRecord) ProtoMessage()
func (*WriteRecord) Reset ¶
func (m *WriteRecord) Reset()
func (*WriteRecord) String ¶
func (m *WriteRecord) String() string
func (*WriteRecord) XXX_DiscardUnknown ¶
func (m *WriteRecord) XXX_DiscardUnknown()
func (*WriteRecord) XXX_Marshal ¶
func (m *WriteRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteRecord) XXX_Merge ¶
func (m *WriteRecord) XXX_Merge(src proto.Message)
func (*WriteRecord) XXX_OneofWrappers ¶
func (*WriteRecord) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*WriteRecord) XXX_Size ¶
func (m *WriteRecord) XXX_Size() int
func (*WriteRecord) XXX_Unmarshal ¶
func (m *WriteRecord) XXX_Unmarshal(b []byte) error
type WriteRecord_Kafka ¶
type WriteRequest ¶
type WriteRequest struct { // Every gRPC request must have a valid auth config Auth *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"` ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` // We need to use a WriteRecord as a wrapper since there is no way to "repeated oneof ..." Records []*WriteRecord `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"` EncodeOptions *encoding.Options `protobuf:"bytes,3,opt,name=encode_options,json=encodeOptions,proto3" json:"encode_options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WriteRequest) Descriptor ¶
func (*WriteRequest) Descriptor() ([]byte, []int)
func (*WriteRequest) GetAuth ¶
func (m *WriteRequest) GetAuth() *common.Auth
func (*WriteRequest) GetConnectionId ¶
func (m *WriteRequest) GetConnectionId() string
func (*WriteRequest) GetEncodeOptions ¶ added in v0.0.14
func (m *WriteRequest) GetEncodeOptions() *encoding.Options
func (*WriteRequest) GetRecords ¶
func (m *WriteRequest) GetRecords() []*WriteRecord
func (*WriteRequest) ProtoMessage ¶
func (*WriteRequest) ProtoMessage()
func (*WriteRequest) Reset ¶
func (m *WriteRequest) Reset()
func (*WriteRequest) String ¶
func (m *WriteRequest) String() string
func (*WriteRequest) XXX_DiscardUnknown ¶
func (m *WriteRequest) XXX_DiscardUnknown()
func (*WriteRequest) XXX_Marshal ¶
func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteRequest) XXX_Merge ¶
func (m *WriteRequest) XXX_Merge(src proto.Message)
func (*WriteRequest) XXX_Size ¶
func (m *WriteRequest) XXX_Size() int
func (*WriteRequest) XXX_Unmarshal ¶
func (m *WriteRequest) XXX_Unmarshal(b []byte) error
type WriteResponse ¶
type WriteResponse struct { Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WriteResponse) Descriptor ¶
func (*WriteResponse) Descriptor() ([]byte, []int)
func (*WriteResponse) GetStatus ¶
func (m *WriteResponse) GetStatus() *common.Status
func (*WriteResponse) ProtoMessage ¶
func (*WriteResponse) ProtoMessage()
func (*WriteResponse) Reset ¶
func (m *WriteResponse) Reset()
func (*WriteResponse) String ¶
func (m *WriteResponse) String() string
func (*WriteResponse) XXX_DiscardUnknown ¶
func (m *WriteResponse) XXX_DiscardUnknown()
func (*WriteResponse) XXX_Marshal ¶
func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteResponse) XXX_Merge ¶
func (m *WriteResponse) XXX_Merge(src proto.Message)
func (*WriteResponse) XXX_Size ¶
func (m *WriteResponse) XXX_Size() int
func (*WriteResponse) XXX_Unmarshal ¶
func (m *WriteResponse) XXX_Unmarshal(b []byte) error