protos

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2021 License: Apache-2.0 Imports: 12 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ReadOptions_Type_name = map[int32]string{
	0: "ONE_TIME",
	1: "CONTINUOUS",
}
View Source
var ReadOptions_Type_value = map[string]int32{
	"ONE_TIME":   0,
	"CONTINUOUS": 1,
}
View Source
var SampleOptions_Interval_name = map[int32]string{
	0: "SECOND",
	1: "MINUTE",
	2: "HOUR",
}
View Source
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 Connection_Kafka struct {
	Kafka *conns.Kafka `protobuf:"bytes,100,opt,name=kafka,proto3,oneof"`
}

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"`
	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 (*CreateConnectionResponse) Descriptor

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

func (*CreateConnectionResponse) GetConnectionId

func (m *CreateConnectionResponse) GetConnectionId() string

func (*CreateConnectionResponse) GetStatus

func (m *CreateConnectionResponse) GetStatus() *common.Status

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 CreateRelayRequest_Kafka

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

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"`
	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 (*GetAllConnectionsResponse) Descriptor

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

func (*GetAllConnectionsResponse) GetConnections

func (m *GetAllConnectionsResponse) GetConnections() []*Connection

func (*GetAllConnectionsResponse) GetStatus

func (m *GetAllConnectionsResponse) GetStatus() *common.Status

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"`
	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 (*GetConnectionResponse) Descriptor

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

func (*GetConnectionResponse) GetConnection

func (m *GetConnectionResponse) GetConnection() *Connection

func (*GetConnectionResponse) GetStatus

func (m *GetConnectionResponse) GetStatus() *common.Status

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
	GetCollection(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
	GetCollection(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) Descriptor() ([]byte, []int)

func (*Relay) GetArgs

func (m *Relay) GetArgs() isRelay_Args

func (*Relay) GetBatchCollectionToken

func (m *Relay) GetBatchCollectionToken() string

func (*Relay) GetBatchMaxRetry

func (m *Relay) GetBatchMaxRetry() int32

func (*Relay) GetBatchSize

func (m *Relay) GetBatchSize() int32

func (*Relay) GetBatchshGrpcAddress

func (m *Relay) GetBatchshGrpcAddress() string

func (*Relay) GetBatchshGrpcDisableTls

func (m *Relay) GetBatchshGrpcDisableTls() bool

func (*Relay) GetBatchshGrpcTimeout

func (m *Relay) GetBatchshGrpcTimeout() bool

func (*Relay) GetConnectionId

func (m *Relay) GetConnectionId() string

func (*Relay) GetKafka

func (m *Relay) GetKafka() *args.Kafka

func (*Relay) ProtoMessage

func (*Relay) ProtoMessage()

func (*Relay) Reset

func (m *Relay) Reset()

func (*Relay) String

func (m *Relay) String() string

func (*Relay) XXX_DiscardUnknown

func (m *Relay) XXX_DiscardUnknown()

func (*Relay) XXX_Marshal

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

func (*Relay) XXX_Merge

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

func (*Relay) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Relay) XXX_Size

func (m *Relay) XXX_Size() int

func (*Relay) XXX_Unmarshal

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

type Relay_Kafka

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

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 StartReadRequest_Kafka struct {
	Kafka *args.Kafka `protobuf:"bytes,100,opt,name=kafka,proto3,oneof"`
}

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) CreateRelay

func (*UnimplementedPlumberServerServer) DeleteConnection

func (*UnimplementedPlumberServerServer) DeleteRelay

func (*UnimplementedPlumberServerServer) GetAllConnections

func (*UnimplementedPlumberServerServer) GetCollection

func (*UnimplementedPlumberServerServer) StartRead

func (*UnimplementedPlumberServerServer) StopRead

func (*UnimplementedPlumberServerServer) StopRelay

func (*UnimplementedPlumberServerServer) TestConnection

func (*UnimplementedPlumberServerServer) UpdateConnection

func (*UnimplementedPlumberServerServer) UpdateRelay

func (*UnimplementedPlumberServerServer) Write

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 WriteRecord_Kafka struct {
	Kafka *records.Kafka `protobuf:"bytes,100,opt,name=kafka,proto3,oneof"`
}

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"`
	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) 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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL