protos

package
v0.0.37 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var PollGithubAuthResponse_Status_name = map[int32]string{
	0: "PENDING",
	1: "SUCCESS",
	2: "FAILED",
}
View Source 
var PollGithubAuthResponse_Status_value = map[string]int32{
	"PENDING": 0,
	"SUCCESS": 1,
	"FAILED":  2,
}
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",
}
View Source 
var SampleOptions_Interval_value = map[string]int32{
	"SECOND": 0,
	"MINUTE": 1,
}

Functions

func RegisterPlumberServerServer 

func RegisterPlumberServerServer(s *grpc.Server, srv PlumberServerServer)

Types

type ConnectionConfig added in v0.0.35 

type ConnectionConfig 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"`
	Id    string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Conn:
	//	*ConnectionConfig_Kafka
	//	*ConnectionConfig_ActiveMq
	//	*ConnectionConfig_Awssqs
	//	*ConnectionConfig_Awssns
	//	*ConnectionConfig_Mongo
	//	*ConnectionConfig_Nats
	//	*ConnectionConfig_NatsStreaming
	//	*ConnectionConfig_Nsq
	//	*ConnectionConfig_Postgres
	//	*ConnectionConfig_Pulsar
	//	*ConnectionConfig_Rabbit
	//	*ConnectionConfig_RabbitStreams
	//	*ConnectionConfig_RedisPubsub
	//	*ConnectionConfig_RedisStreams
	//	*ConnectionConfig_AzureEventHub
	//	*ConnectionConfig_AzureServiceBus
	Conn                 isConnectionConfig_Conn `protobuf_oneof:"conn"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ConnectionConfig) Descriptor added in v0.0.35 

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

func (*ConnectionConfig) GetActiveMq added in v0.0.35 

func (m *ConnectionConfig) GetActiveMq() *conns.ActiveMQ

func (*ConnectionConfig) GetAwssns added in v0.0.35 

func (m *ConnectionConfig) GetAwssns() *conns.AWSSNS

func (*ConnectionConfig) GetAwssqs added in v0.0.35 

func (m *ConnectionConfig) GetAwssqs() *conns.AWSSQS

func (*ConnectionConfig) GetAzureEventHub added in v0.0.35 

func (m *ConnectionConfig) GetAzureEventHub() *conns.AzureEventHub

func (*ConnectionConfig) GetAzureServiceBus added in v0.0.35 

func (m *ConnectionConfig) GetAzureServiceBus() *conns.AzureServiceBus

func (*ConnectionConfig) GetConn added in v0.0.35 

func (m *ConnectionConfig) GetConn() isConnectionConfig_Conn

func (*ConnectionConfig) GetId added in v0.0.35 

func (m *ConnectionConfig) GetId() string

func (*ConnectionConfig) GetKafka added in v0.0.35 

func (m *ConnectionConfig) GetKafka() *conns.Kafka

func (*ConnectionConfig) GetMongo added in v0.0.35 

func (m *ConnectionConfig) GetMongo() *conns.Mongo

func (*ConnectionConfig) GetName added in v0.0.35 

func (m *ConnectionConfig) GetName() string

func (*ConnectionConfig) GetNats added in v0.0.35 

func (m *ConnectionConfig) GetNats() *conns.Nats

func (*ConnectionConfig) GetNatsStreaming added in v0.0.35 

func (m *ConnectionConfig) GetNatsStreaming() *conns.NatsStreaming

func (*ConnectionConfig) GetNotes added in v0.0.35 

func (m *ConnectionConfig) GetNotes() string

func (*ConnectionConfig) GetNsq added in v0.0.35 

func (m *ConnectionConfig) GetNsq() *conns.NSQ

func (*ConnectionConfig) GetPostgres added in v0.0.35 

func (m *ConnectionConfig) GetPostgres() *conns.Postgres

func (*ConnectionConfig) GetPulsar added in v0.0.35 

func (m *ConnectionConfig) GetPulsar() *conns.Pulsar

func (*ConnectionConfig) GetRabbit added in v0.0.35 

func (m *ConnectionConfig) GetRabbit() *conns.Rabbit

func (*ConnectionConfig) GetRabbitStreams added in v0.0.35 

func (m *ConnectionConfig) GetRabbitStreams() *conns.RabbitStreams

func (*ConnectionConfig) GetRedisPubsub added in v0.0.35 

func (m *ConnectionConfig) GetRedisPubsub() *conns.RedisPubsub

func (*ConnectionConfig) GetRedisStreams added in v0.0.35 

func (m *ConnectionConfig) GetRedisStreams() *conns.RedisStreams

func (*ConnectionConfig) ProtoMessage added in v0.0.35 

func (*ConnectionConfig) ProtoMessage()

func (*ConnectionConfig) Reset added in v0.0.35 

func (m *ConnectionConfig) Reset()

func (*ConnectionConfig) String added in v0.0.35 

func (m *ConnectionConfig) String() string

func (*ConnectionConfig) XXX_DiscardUnknown added in v0.0.35 

func (m *ConnectionConfig) XXX_DiscardUnknown()

func (*ConnectionConfig) XXX_Marshal added in v0.0.35 

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

func (*ConnectionConfig) XXX_Merge added in v0.0.35 

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

func (*ConnectionConfig) XXX_OneofWrappers added in v0.0.35 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConnectionConfig) XXX_Size added in v0.0.35 

func (m *ConnectionConfig) XXX_Size() int

func (*ConnectionConfig) XXX_Unmarshal added in v0.0.35 

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

type ConnectionConfig_ActiveMq added in v0.0.35 

type ConnectionConfig_ActiveMq struct {
	ActiveMq *conns.ActiveMQ `protobuf:"bytes,101,opt,name=active_mq,json=activeMq,proto3,oneof"`
}

type ConnectionConfig_Awssns added in v0.0.35 

type ConnectionConfig_Awssns struct {
	Awssns *conns.AWSSNS `protobuf:"bytes,103,opt,name=awssns,proto3,oneof"`
}

type ConnectionConfig_Awssqs added in v0.0.35 

type ConnectionConfig_Awssqs struct {
	Awssqs *conns.AWSSQS `protobuf:"bytes,102,opt,name=awssqs,proto3,oneof"`
}

type ConnectionConfig_AzureEventHub added in v0.0.35 

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

type ConnectionConfig_AzureServiceBus added in v0.0.35 

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

type ConnectionConfig_Kafka added in v0.0.35 

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

type ConnectionConfig_Mongo added in v0.0.35 

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

type ConnectionConfig_Nats added in v0.0.35 

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

type ConnectionConfig_NatsStreaming added in v0.0.35 

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

type ConnectionConfig_Nsq added in v0.0.35 

type ConnectionConfig_Nsq struct {
	Nsq *conns.NSQ `protobuf:"bytes,107,opt,name=nsq,proto3,oneof"`
}

type ConnectionConfig_Postgres added in v0.0.35 

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

type ConnectionConfig_Pulsar added in v0.0.35 

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

type ConnectionConfig_Rabbit added in v0.0.35 

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

type ConnectionConfig_RabbitStreams added in v0.0.35 

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

type ConnectionConfig_RedisPubsub added in v0.0.35 

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

type ConnectionConfig_RedisStreams added in v0.0.35 

type ConnectionConfig_RedisStreams struct {
	RedisStreams *conns.RedisStreams `protobuf:"bytes,113,opt,name=redis_streams,json=redisStreams,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"`
	Config               *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,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) GetConfig added in v0.0.35 

func (m *CreateConnectionRequest) GetConfig() *ConnectionConfig

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 CreateReadRequest added in v0.0.20 

type CreateReadRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Config               *ReadConfig  `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CreateReadRequest) Descriptor added in v0.0.20 

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

func (*CreateReadRequest) GetAuth added in v0.0.20 

func (m *CreateReadRequest) GetAuth() *common.Auth

func (*CreateReadRequest) GetConfig added in v0.0.34 

func (m *CreateReadRequest) GetConfig() *ReadConfig

func (*CreateReadRequest) ProtoMessage added in v0.0.20 

func (*CreateReadRequest) ProtoMessage()

func (*CreateReadRequest) Reset added in v0.0.20 

func (m *CreateReadRequest) Reset()

func (*CreateReadRequest) String added in v0.0.20 

func (m *CreateReadRequest) String() string

func (*CreateReadRequest) XXX_DiscardUnknown added in v0.0.20 

func (m *CreateReadRequest) XXX_DiscardUnknown()

func (*CreateReadRequest) XXX_Marshal added in v0.0.20 

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

func (*CreateReadRequest) XXX_Merge added in v0.0.20 

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

func (*CreateReadRequest) XXX_Size added in v0.0.20 

func (m *CreateReadRequest) XXX_Size() int

func (*CreateReadRequest) XXX_Unmarshal added in v0.0.20 

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

type CreateReadResponse added in v0.0.20 

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

func (*CreateReadResponse) Descriptor added in v0.0.20 

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

func (*CreateReadResponse) GetReadId added in v0.0.20 

func (m *CreateReadResponse) GetReadId() string

func (*CreateReadResponse) GetStatus added in v0.0.20 

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

func (*CreateReadResponse) ProtoMessage added in v0.0.20 

func (*CreateReadResponse) ProtoMessage()

func (*CreateReadResponse) Reset added in v0.0.20 

func (m *CreateReadResponse) Reset()

func (*CreateReadResponse) String added in v0.0.20 

func (m *CreateReadResponse) String() string

func (*CreateReadResponse) XXX_DiscardUnknown added in v0.0.20 

func (m *CreateReadResponse) XXX_DiscardUnknown()

func (*CreateReadResponse) XXX_Marshal added in v0.0.20 

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

func (*CreateReadResponse) XXX_Merge added in v0.0.20 

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

func (*CreateReadResponse) XXX_Size added in v0.0.20 

func (m *CreateReadResponse) XXX_Size() int

func (*CreateReadResponse) XXX_Unmarshal added in v0.0.20 

func (m *CreateReadResponse) 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"`
	Config *RelayConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// Types that are valid to be assigned to Backends:
	//	*CreateRelayRequest_Kafka
	//	*CreateRelayRequest_ActiveMq
	//	*CreateRelayRequest_Awssqs
	//	*CreateRelayRequest_Awssns
	//	*CreateRelayRequest_Mongo
	//	*CreateRelayRequest_Nats
	//	*CreateRelayRequest_NatsStreaming
	//	*CreateRelayRequest_Nsq
	//	*CreateRelayRequest_Postgres
	//	*CreateRelayRequest_Pulsar
	//	*CreateRelayRequest_Rabbit
	//	*CreateRelayRequest_RabbitStreams
	//	*CreateRelayRequest_RedisPubsub
	//	*CreateRelayRequest_RedisStreams
	Backends             isCreateRelayRequest_Backends `protobuf_oneof:"Backends"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*CreateRelayRequest) Descriptor 

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

func (*CreateRelayRequest) GetActiveMq added in v0.0.32 

func (m *CreateRelayRequest) GetActiveMq() *backends.ActiveMQ

func (*CreateRelayRequest) GetAuth 

func (m *CreateRelayRequest) GetAuth() *common.Auth

func (*CreateRelayRequest) GetAwssns added in v0.0.32 

func (m *CreateRelayRequest) GetAwssns() *backends.AWSSNS

func (*CreateRelayRequest) GetAwssqs added in v0.0.32 

func (m *CreateRelayRequest) GetAwssqs() *backends.AWSSQS

func (*CreateRelayRequest) GetBackends added in v0.0.31 

func (m *CreateRelayRequest) GetBackends() isCreateRelayRequest_Backends

func (*CreateRelayRequest) GetConfig added in v0.0.37 

func (m *CreateRelayRequest) GetConfig() *RelayConfig

func (*CreateRelayRequest) GetKafka 

func (m *CreateRelayRequest) GetKafka() *backends.Kafka

func (*CreateRelayRequest) GetMongo added in v0.0.32 

func (m *CreateRelayRequest) GetMongo() *backends.Mongo

func (*CreateRelayRequest) GetNats added in v0.0.32 

func (m *CreateRelayRequest) GetNats() *backends.Nats

func (*CreateRelayRequest) GetNatsStreaming added in v0.0.32 

func (m *CreateRelayRequest) GetNatsStreaming() *backends.NatsStreaming

func (*CreateRelayRequest) GetNsq added in v0.0.32 

func (m *CreateRelayRequest) GetNsq() *backends.NSQ

func (*CreateRelayRequest) GetPostgres added in v0.0.32 

func (m *CreateRelayRequest) GetPostgres() *backends.Postgres

func (*CreateRelayRequest) GetPulsar added in v0.0.32 

func (m *CreateRelayRequest) GetPulsar() *backends.Pulsar

func (*CreateRelayRequest) GetRabbit added in v0.0.32 

func (m *CreateRelayRequest) GetRabbit() *backends.Rabbit

func (*CreateRelayRequest) GetRabbitStreams added in v0.0.32 

func (m *CreateRelayRequest) GetRabbitStreams() *backends.RabbitStreams

func (*CreateRelayRequest) GetRedisPubsub added in v0.0.32 

func (m *CreateRelayRequest) GetRedisPubsub() *backends.RedisPubsub

func (*CreateRelayRequest) GetRedisStreams added in v0.0.32 

func (m *CreateRelayRequest) GetRedisStreams() *backends.RedisStreams

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_ActiveMq added in v0.0.32 

type CreateRelayRequest_ActiveMq struct {
	ActiveMq *backends.ActiveMQ `protobuf:"bytes,101,opt,name=active_mq,json=activeMq,proto3,oneof"`
}

type CreateRelayRequest_Awssns added in v0.0.32 

type CreateRelayRequest_Awssns struct {
	Awssns *backends.AWSSNS `protobuf:"bytes,103,opt,name=awssns,proto3,oneof"`
}

type CreateRelayRequest_Awssqs added in v0.0.32 

type CreateRelayRequest_Awssqs struct {
	Awssqs *backends.AWSSQS `protobuf:"bytes,102,opt,name=awssqs,proto3,oneof"`
}

type CreateRelayRequest_Kafka 

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

type CreateRelayRequest_Mongo added in v0.0.32 

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

type CreateRelayRequest_Nats added in v0.0.32 

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

type CreateRelayRequest_NatsStreaming added in v0.0.32 

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

type CreateRelayRequest_Nsq added in v0.0.32 

type CreateRelayRequest_Nsq struct {
	Nsq *backends.NSQ `protobuf:"bytes,107,opt,name=nsq,proto3,oneof"`
}

type CreateRelayRequest_Postgres added in v0.0.32 

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

type CreateRelayRequest_Pulsar added in v0.0.32 

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

type CreateRelayRequest_Rabbit added in v0.0.32 

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

type CreateRelayRequest_RabbitStreams added in v0.0.32 

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

type CreateRelayRequest_RedisPubsub added in v0.0.32 

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

type CreateRelayRequest_RedisStreams added in v0.0.32 

type CreateRelayRequest_RedisStreams struct {
	RedisStreams *backends.RedisStreams `protobuf:"bytes,113,opt,name=redis_streams,json=redisStreams,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 CreateServiceRequest added in v0.0.27 

type CreateServiceRequest struct {
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Service              *Service     `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CreateServiceRequest) Descriptor added in v0.0.27 

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

func (*CreateServiceRequest) GetAuth added in v0.0.27 

func (m *CreateServiceRequest) GetAuth() *common.Auth

func (*CreateServiceRequest) GetService added in v0.0.27 

func (m *CreateServiceRequest) GetService() *Service

func (*CreateServiceRequest) ProtoMessage added in v0.0.27 

func (*CreateServiceRequest) ProtoMessage()

func (*CreateServiceRequest) Reset added in v0.0.27 

func (m *CreateServiceRequest) Reset()

func (*CreateServiceRequest) String added in v0.0.27 

func (m *CreateServiceRequest) String() string

func (*CreateServiceRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *CreateServiceRequest) XXX_DiscardUnknown()

func (*CreateServiceRequest) XXX_Marshal added in v0.0.27 

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

func (*CreateServiceRequest) XXX_Merge added in v0.0.27 

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

func (*CreateServiceRequest) XXX_Size added in v0.0.27 

func (m *CreateServiceRequest) XXX_Size() int

func (*CreateServiceRequest) XXX_Unmarshal added in v0.0.27 

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

type CreateServiceResponse added in v0.0.27 

type CreateServiceResponse struct {
	Service              *Service       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,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 (*CreateServiceResponse) Descriptor added in v0.0.27 

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

func (*CreateServiceResponse) GetService added in v0.0.27 

func (m *CreateServiceResponse) GetService() *Service

func (*CreateServiceResponse) GetStatus added in v0.0.27 

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

func (*CreateServiceResponse) ProtoMessage added in v0.0.27 

func (*CreateServiceResponse) ProtoMessage()

func (*CreateServiceResponse) Reset added in v0.0.27 

func (m *CreateServiceResponse) Reset()

func (*CreateServiceResponse) String added in v0.0.27 

func (m *CreateServiceResponse) String() string

func (*CreateServiceResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *CreateServiceResponse) XXX_DiscardUnknown()

func (*CreateServiceResponse) XXX_Marshal added in v0.0.27 

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

func (*CreateServiceResponse) XXX_Merge added in v0.0.27 

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

func (*CreateServiceResponse) XXX_Size added in v0.0.27 

func (m *CreateServiceResponse) XXX_Size() int

func (*CreateServiceResponse) XXX_Unmarshal added in v0.0.27 

func (m *CreateServiceResponse) 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 DeleteReadRequest added in v0.0.20 

type DeleteReadRequest 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 (*DeleteReadRequest) Descriptor added in v0.0.20 

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

func (*DeleteReadRequest) GetAuth added in v0.0.20 

func (m *DeleteReadRequest) GetAuth() *common.Auth

func (*DeleteReadRequest) GetReadId added in v0.0.20 

func (m *DeleteReadRequest) GetReadId() string

func (*DeleteReadRequest) ProtoMessage added in v0.0.20 

func (*DeleteReadRequest) ProtoMessage()

func (*DeleteReadRequest) Reset added in v0.0.20 

func (m *DeleteReadRequest) Reset()

func (*DeleteReadRequest) String added in v0.0.20 

func (m *DeleteReadRequest) String() string

func (*DeleteReadRequest) XXX_DiscardUnknown added in v0.0.20 

func (m *DeleteReadRequest) XXX_DiscardUnknown()

func (*DeleteReadRequest) XXX_Marshal added in v0.0.20 

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

func (*DeleteReadRequest) XXX_Merge added in v0.0.20 

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

func (*DeleteReadRequest) XXX_Size added in v0.0.20 

func (m *DeleteReadRequest) XXX_Size() int

func (*DeleteReadRequest) XXX_Unmarshal added in v0.0.20 

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

type DeleteReadResponse added in v0.0.20 

type DeleteReadResponse 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 (*DeleteReadResponse) Descriptor added in v0.0.20 

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

func (*DeleteReadResponse) GetStatus added in v0.0.20 

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

func (*DeleteReadResponse) ProtoMessage added in v0.0.20 

func (*DeleteReadResponse) ProtoMessage()

func (*DeleteReadResponse) Reset added in v0.0.20 

func (m *DeleteReadResponse) Reset()

func (*DeleteReadResponse) String added in v0.0.20 

func (m *DeleteReadResponse) String() string

func (*DeleteReadResponse) XXX_DiscardUnknown added in v0.0.20 

func (m *DeleteReadResponse) XXX_DiscardUnknown()

func (*DeleteReadResponse) XXX_Marshal added in v0.0.20 

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

func (*DeleteReadResponse) XXX_Merge added in v0.0.20 

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

func (*DeleteReadResponse) XXX_Size added in v0.0.20 

func (m *DeleteReadResponse) XXX_Size() int

func (*DeleteReadResponse) XXX_Unmarshal added in v0.0.20 

func (m *DeleteReadResponse) 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 DeleteSchemaRequest added in v0.0.26 

type DeleteSchemaRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Id                   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteSchemaRequest) Descriptor added in v0.0.26 

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

func (*DeleteSchemaRequest) GetAuth added in v0.0.26 

func (m *DeleteSchemaRequest) GetAuth() *common.Auth

func (*DeleteSchemaRequest) GetId added in v0.0.26 

func (m *DeleteSchemaRequest) GetId() string

func (*DeleteSchemaRequest) ProtoMessage added in v0.0.26 

func (*DeleteSchemaRequest) ProtoMessage()

func (*DeleteSchemaRequest) Reset added in v0.0.26 

func (m *DeleteSchemaRequest) Reset()

func (*DeleteSchemaRequest) String added in v0.0.26 

func (m *DeleteSchemaRequest) String() string

func (*DeleteSchemaRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *DeleteSchemaRequest) XXX_DiscardUnknown()

func (*DeleteSchemaRequest) XXX_Marshal added in v0.0.26 

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

func (*DeleteSchemaRequest) XXX_Merge added in v0.0.26 

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

func (*DeleteSchemaRequest) XXX_Size added in v0.0.26 

func (m *DeleteSchemaRequest) XXX_Size() int

func (*DeleteSchemaRequest) XXX_Unmarshal added in v0.0.26 

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

type DeleteSchemaResponse added in v0.0.26 

type DeleteSchemaResponse 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 (*DeleteSchemaResponse) Descriptor added in v0.0.26 

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

func (*DeleteSchemaResponse) GetStatus added in v0.0.26 

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

func (*DeleteSchemaResponse) ProtoMessage added in v0.0.26 

func (*DeleteSchemaResponse) ProtoMessage()

func (*DeleteSchemaResponse) Reset added in v0.0.26 

func (m *DeleteSchemaResponse) Reset()

func (*DeleteSchemaResponse) String added in v0.0.26 

func (m *DeleteSchemaResponse) String() string

func (*DeleteSchemaResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *DeleteSchemaResponse) XXX_DiscardUnknown()

func (*DeleteSchemaResponse) XXX_Marshal added in v0.0.26 

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

func (*DeleteSchemaResponse) XXX_Merge added in v0.0.26 

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

func (*DeleteSchemaResponse) XXX_Size added in v0.0.26 

func (m *DeleteSchemaResponse) XXX_Size() int

func (*DeleteSchemaResponse) XXX_Unmarshal added in v0.0.26 

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

type DeleteServiceRequest added in v0.0.27 

type DeleteServiceRequest struct {
	Id                   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	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 (*DeleteServiceRequest) Descriptor added in v0.0.27 

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

func (*DeleteServiceRequest) GetAuth added in v0.0.27 

func (m *DeleteServiceRequest) GetAuth() *common.Auth

func (*DeleteServiceRequest) GetId added in v0.0.27 

func (m *DeleteServiceRequest) GetId() string

func (*DeleteServiceRequest) ProtoMessage added in v0.0.27 

func (*DeleteServiceRequest) ProtoMessage()

func (*DeleteServiceRequest) Reset added in v0.0.27 

func (m *DeleteServiceRequest) Reset()

func (*DeleteServiceRequest) String added in v0.0.27 

func (m *DeleteServiceRequest) String() string

func (*DeleteServiceRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *DeleteServiceRequest) XXX_DiscardUnknown()

func (*DeleteServiceRequest) XXX_Marshal added in v0.0.27 

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

func (*DeleteServiceRequest) XXX_Merge added in v0.0.27 

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

func (*DeleteServiceRequest) XXX_Size added in v0.0.27 

func (m *DeleteServiceRequest) XXX_Size() int

func (*DeleteServiceRequest) XXX_Unmarshal added in v0.0.27 

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

type DeleteServiceResponse added in v0.0.27 

type DeleteServiceResponse 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 (*DeleteServiceResponse) Descriptor added in v0.0.27 

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

func (*DeleteServiceResponse) GetStatus added in v0.0.27 

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

func (*DeleteServiceResponse) ProtoMessage added in v0.0.27 

func (*DeleteServiceResponse) ProtoMessage()

func (*DeleteServiceResponse) Reset added in v0.0.27 

func (m *DeleteServiceResponse) Reset()

func (*DeleteServiceResponse) String added in v0.0.27 

func (m *DeleteServiceResponse) String() string

func (*DeleteServiceResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *DeleteServiceResponse) XXX_DiscardUnknown()

func (*DeleteServiceResponse) XXX_Marshal added in v0.0.27 

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

func (*DeleteServiceResponse) XXX_Merge added in v0.0.27 

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

func (*DeleteServiceResponse) XXX_Size added in v0.0.27 

func (m *DeleteServiceResponse) XXX_Size() int

func (*DeleteServiceResponse) XXX_Unmarshal added in v0.0.27 

func (m *DeleteServiceResponse) 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 {
	Configs              []*ConnectionConfig `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetAllConnectionsResponse) Descriptor 

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

func (*GetAllConnectionsResponse) GetConfigs added in v0.0.35 

func (m *GetAllConnectionsResponse) GetConfigs() []*ConnectionConfig

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 GetAllReadsRequest added in v0.0.18 

type GetAllReadsRequest 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 (*GetAllReadsRequest) Descriptor added in v0.0.18 

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

func (*GetAllReadsRequest) GetAuth added in v0.0.18 

func (m *GetAllReadsRequest) GetAuth() *common.Auth

func (*GetAllReadsRequest) ProtoMessage added in v0.0.18 

func (*GetAllReadsRequest) ProtoMessage()

func (*GetAllReadsRequest) Reset added in v0.0.18 

func (m *GetAllReadsRequest) Reset()

func (*GetAllReadsRequest) String added in v0.0.18 

func (m *GetAllReadsRequest) String() string

func (*GetAllReadsRequest) XXX_DiscardUnknown added in v0.0.18 

func (m *GetAllReadsRequest) XXX_DiscardUnknown()

func (*GetAllReadsRequest) XXX_Marshal added in v0.0.18 

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

func (*GetAllReadsRequest) XXX_Merge added in v0.0.18 

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

func (*GetAllReadsRequest) XXX_Size added in v0.0.18 

func (m *GetAllReadsRequest) XXX_Size() int

func (*GetAllReadsRequest) XXX_Unmarshal added in v0.0.18 

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

type GetAllReadsResponse added in v0.0.18 

type GetAllReadsResponse struct {
	Read                 []*ReadConfig  `protobuf:"bytes,1,rep,name=read,proto3" json:"read,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 (*GetAllReadsResponse) Descriptor added in v0.0.18 

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

func (*GetAllReadsResponse) GetRead added in v0.0.18 

func (m *GetAllReadsResponse) GetRead() []*ReadConfig

func (*GetAllReadsResponse) GetStatus added in v0.0.18 

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

func (*GetAllReadsResponse) ProtoMessage added in v0.0.18 

func (*GetAllReadsResponse) ProtoMessage()

func (*GetAllReadsResponse) Reset added in v0.0.18 

func (m *GetAllReadsResponse) Reset()

func (*GetAllReadsResponse) String added in v0.0.18 

func (m *GetAllReadsResponse) String() string

func (*GetAllReadsResponse) XXX_DiscardUnknown added in v0.0.18 

func (m *GetAllReadsResponse) XXX_DiscardUnknown()

func (*GetAllReadsResponse) XXX_Marshal added in v0.0.18 

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

func (*GetAllReadsResponse) XXX_Merge added in v0.0.18 

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

func (*GetAllReadsResponse) XXX_Size added in v0.0.18 

func (m *GetAllReadsResponse) XXX_Size() int

func (*GetAllReadsResponse) XXX_Unmarshal added in v0.0.18 

func (m *GetAllReadsResponse) 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
	Configs              []*RelayConfig `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetAllRelaysResponse) Descriptor 

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

func (*GetAllRelaysResponse) GetConfigs added in v0.0.34 

func (m *GetAllRelaysResponse) GetConfigs() []*RelayConfig

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 GetAllSchemasRequest added in v0.0.26 

type GetAllSchemasRequest 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 (*GetAllSchemasRequest) Descriptor added in v0.0.26 

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

func (*GetAllSchemasRequest) GetAuth added in v0.0.26 

func (m *GetAllSchemasRequest) GetAuth() *common.Auth

func (*GetAllSchemasRequest) ProtoMessage added in v0.0.26 

func (*GetAllSchemasRequest) ProtoMessage()

func (*GetAllSchemasRequest) Reset added in v0.0.26 

func (m *GetAllSchemasRequest) Reset()

func (*GetAllSchemasRequest) String added in v0.0.26 

func (m *GetAllSchemasRequest) String() string

func (*GetAllSchemasRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *GetAllSchemasRequest) XXX_DiscardUnknown()

func (*GetAllSchemasRequest) XXX_Marshal added in v0.0.26 

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

func (*GetAllSchemasRequest) XXX_Merge added in v0.0.26 

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

func (*GetAllSchemasRequest) XXX_Size added in v0.0.26 

func (m *GetAllSchemasRequest) XXX_Size() int

func (*GetAllSchemasRequest) XXX_Unmarshal added in v0.0.26 

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

type GetAllSchemasResponse added in v0.0.26 

type GetAllSchemasResponse struct {
	Schema               []*Schema `protobuf:"bytes,1,rep,name=schema,proto3" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetAllSchemasResponse) Descriptor added in v0.0.26 

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

func (*GetAllSchemasResponse) GetSchema added in v0.0.26 

func (m *GetAllSchemasResponse) GetSchema() []*Schema

func (*GetAllSchemasResponse) ProtoMessage added in v0.0.26 

func (*GetAllSchemasResponse) ProtoMessage()

func (*GetAllSchemasResponse) Reset added in v0.0.26 

func (m *GetAllSchemasResponse) Reset()

func (*GetAllSchemasResponse) String added in v0.0.26 

func (m *GetAllSchemasResponse) String() string

func (*GetAllSchemasResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *GetAllSchemasResponse) XXX_DiscardUnknown()

func (*GetAllSchemasResponse) XXX_Marshal added in v0.0.26 

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

func (*GetAllSchemasResponse) XXX_Merge added in v0.0.26 

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

func (*GetAllSchemasResponse) XXX_Size added in v0.0.26 

func (m *GetAllSchemasResponse) XXX_Size() int

func (*GetAllSchemasResponse) XXX_Unmarshal added in v0.0.26 

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

type GetAllServicesRequest added in v0.0.27 

type GetAllServicesRequest struct {
	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 (*GetAllServicesRequest) Descriptor added in v0.0.27 

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

func (*GetAllServicesRequest) GetAuth added in v0.0.27 

func (m *GetAllServicesRequest) GetAuth() *common.Auth

func (*GetAllServicesRequest) ProtoMessage added in v0.0.27 

func (*GetAllServicesRequest) ProtoMessage()

func (*GetAllServicesRequest) Reset added in v0.0.27 

func (m *GetAllServicesRequest) Reset()

func (*GetAllServicesRequest) String added in v0.0.27 

func (m *GetAllServicesRequest) String() string

func (*GetAllServicesRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *GetAllServicesRequest) XXX_DiscardUnknown()

func (*GetAllServicesRequest) XXX_Marshal added in v0.0.27 

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

func (*GetAllServicesRequest) XXX_Merge added in v0.0.27 

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

func (*GetAllServicesRequest) XXX_Size added in v0.0.27 

func (m *GetAllServicesRequest) XXX_Size() int

func (*GetAllServicesRequest) XXX_Unmarshal added in v0.0.27 

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

type GetAllServicesResponse added in v0.0.27 

type GetAllServicesResponse struct {
	Services             []*Service     `protobuf:"bytes,1,rep,name=services,proto3" json:"services,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 (*GetAllServicesResponse) Descriptor added in v0.0.27 

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

func (*GetAllServicesResponse) GetServices added in v0.0.27 

func (m *GetAllServicesResponse) GetServices() []*Service

func (*GetAllServicesResponse) GetStatus added in v0.0.27 

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

func (*GetAllServicesResponse) ProtoMessage added in v0.0.27 

func (*GetAllServicesResponse) ProtoMessage()

func (*GetAllServicesResponse) Reset added in v0.0.27 

func (m *GetAllServicesResponse) Reset()

func (*GetAllServicesResponse) String added in v0.0.27 

func (m *GetAllServicesResponse) String() string

func (*GetAllServicesResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *GetAllServicesResponse) XXX_DiscardUnknown()

func (*GetAllServicesResponse) XXX_Marshal added in v0.0.27 

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

func (*GetAllServicesResponse) XXX_Merge added in v0.0.27 

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

func (*GetAllServicesResponse) XXX_Size added in v0.0.27 

func (m *GetAllServicesResponse) XXX_Size() int

func (*GetAllServicesResponse) XXX_Unmarshal added in v0.0.27 

func (m *GetAllServicesResponse) 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           *ConnectionConfig `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() *ConnectionConfig

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
	Config               *RelayConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetRelayResponse) Descriptor 

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

func (*GetRelayResponse) GetConfig added in v0.0.34 

func (m *GetRelayResponse) GetConfig() *RelayConfig

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 GetSchemaRequest added in v0.0.26 

type GetSchemaRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Id                   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetSchemaRequest) Descriptor added in v0.0.26 

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

func (*GetSchemaRequest) GetAuth added in v0.0.26 

func (m *GetSchemaRequest) GetAuth() *common.Auth

func (*GetSchemaRequest) GetId added in v0.0.26 

func (m *GetSchemaRequest) GetId() string

func (*GetSchemaRequest) ProtoMessage added in v0.0.26 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) Reset added in v0.0.26 

func (m *GetSchemaRequest) Reset()

func (*GetSchemaRequest) String added in v0.0.26 

func (m *GetSchemaRequest) String() string

func (*GetSchemaRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *GetSchemaRequest) XXX_DiscardUnknown()

func (*GetSchemaRequest) XXX_Marshal added in v0.0.26 

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

func (*GetSchemaRequest) XXX_Merge added in v0.0.26 

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

func (*GetSchemaRequest) XXX_Size added in v0.0.26 

func (m *GetSchemaRequest) XXX_Size() int

func (*GetSchemaRequest) XXX_Unmarshal added in v0.0.26 

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

type GetSchemaResponse added in v0.0.26 

type GetSchemaResponse struct {
	Schema               *Schema  `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSchemaResponse) Descriptor added in v0.0.26 

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

func (*GetSchemaResponse) GetSchema added in v0.0.26 

func (m *GetSchemaResponse) GetSchema() *Schema

func (*GetSchemaResponse) ProtoMessage added in v0.0.26 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) Reset added in v0.0.26 

func (m *GetSchemaResponse) Reset()

func (*GetSchemaResponse) String added in v0.0.26 

func (m *GetSchemaResponse) String() string

func (*GetSchemaResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *GetSchemaResponse) XXX_DiscardUnknown()

func (*GetSchemaResponse) XXX_Marshal added in v0.0.26 

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

func (*GetSchemaResponse) XXX_Merge added in v0.0.26 

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

func (*GetSchemaResponse) XXX_Size added in v0.0.26 

func (m *GetSchemaResponse) XXX_Size() int

func (*GetSchemaResponse) XXX_Unmarshal added in v0.0.26 

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

type GetServiceRequest added in v0.0.27 

type GetServiceRequest struct {
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Id                   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetServiceRequest) Descriptor added in v0.0.27 

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

func (*GetServiceRequest) GetAuth added in v0.0.27 

func (m *GetServiceRequest) GetAuth() *common.Auth

func (*GetServiceRequest) GetId added in v0.0.27 

func (m *GetServiceRequest) GetId() string

func (*GetServiceRequest) ProtoMessage added in v0.0.27 

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) Reset added in v0.0.27 

func (m *GetServiceRequest) Reset()

func (*GetServiceRequest) String added in v0.0.27 

func (m *GetServiceRequest) String() string

func (*GetServiceRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *GetServiceRequest) XXX_DiscardUnknown()

func (*GetServiceRequest) XXX_Marshal added in v0.0.27 

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

func (*GetServiceRequest) XXX_Merge added in v0.0.27 

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

func (*GetServiceRequest) XXX_Size added in v0.0.27 

func (m *GetServiceRequest) XXX_Size() int

func (*GetServiceRequest) XXX_Unmarshal added in v0.0.27 

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

type GetServiceResponse added in v0.0.27 

type GetServiceResponse struct {
	Service              *Service       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,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 (*GetServiceResponse) Descriptor added in v0.0.27 

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

func (*GetServiceResponse) GetService added in v0.0.27 

func (m *GetServiceResponse) GetService() *Service

func (*GetServiceResponse) GetStatus added in v0.0.27 

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

func (*GetServiceResponse) ProtoMessage added in v0.0.27 

func (*GetServiceResponse) ProtoMessage()

func (*GetServiceResponse) Reset added in v0.0.27 

func (m *GetServiceResponse) Reset()

func (*GetServiceResponse) String added in v0.0.27 

func (m *GetServiceResponse) String() string

func (*GetServiceResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *GetServiceResponse) XXX_DiscardUnknown()

func (*GetServiceResponse) XXX_Marshal added in v0.0.27 

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

func (*GetServiceResponse) XXX_Merge added in v0.0.27 

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

func (*GetServiceResponse) XXX_Size added in v0.0.27 

func (m *GetServiceResponse) XXX_Size() int

func (*GetServiceResponse) XXX_Unmarshal added in v0.0.27 

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

type ImportGithubRequest added in v0.0.26 

type ImportGithubRequest struct {
	// Every gRPC request must have a valid auth config
	Auth      *common.Auth  `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Name      string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type      encoding.Type `protobuf:"varint,2,opt,name=type,proto3,enum=protos.encoding.Type" json:"type,omitempty"`
	GithubUrl string        `protobuf:"bytes,3,opt,name=github_url,json=githubUrl,proto3" json:"github_url,omitempty"`
	// Protobuf only, root message name
	RootType string `protobuf:"bytes,4,opt,name=root_type,json=rootType,proto3" json:"root_type,omitempty"`
	// Directory inside github repo where protos are stored
	RootDir              string   `protobuf:"bytes,5,opt,name=root_dir,json=rootDir,proto3" json:"root_dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportGithubRequest) Descriptor added in v0.0.26 

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

func (*ImportGithubRequest) GetAuth added in v0.0.26 

func (m *ImportGithubRequest) GetAuth() *common.Auth

func (*ImportGithubRequest) GetGithubUrl added in v0.0.26 

func (m *ImportGithubRequest) GetGithubUrl() string

func (*ImportGithubRequest) GetName added in v0.0.26 

func (m *ImportGithubRequest) GetName() string

func (*ImportGithubRequest) GetRootDir added in v0.0.28 

func (m *ImportGithubRequest) GetRootDir() string

func (*ImportGithubRequest) GetRootType added in v0.0.26 

func (m *ImportGithubRequest) GetRootType() string

func (*ImportGithubRequest) GetType added in v0.0.26 

func (m *ImportGithubRequest) GetType() encoding.Type

func (*ImportGithubRequest) ProtoMessage added in v0.0.26 

func (*ImportGithubRequest) ProtoMessage()

func (*ImportGithubRequest) Reset added in v0.0.26 

func (m *ImportGithubRequest) Reset()

func (*ImportGithubRequest) String added in v0.0.26 

func (m *ImportGithubRequest) String() string

func (*ImportGithubRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *ImportGithubRequest) XXX_DiscardUnknown()

func (*ImportGithubRequest) XXX_Marshal added in v0.0.26 

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

func (*ImportGithubRequest) XXX_Merge added in v0.0.26 

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

func (*ImportGithubRequest) XXX_Size added in v0.0.26 

func (m *ImportGithubRequest) XXX_Size() int

func (*ImportGithubRequest) XXX_Unmarshal added in v0.0.26 

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

type ImportGithubResponse added in v0.0.26 

type ImportGithubResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	Id                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ImportGithubResponse) Descriptor added in v0.0.26 

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

func (*ImportGithubResponse) GetId added in v0.0.26 

func (m *ImportGithubResponse) GetId() string

func (*ImportGithubResponse) GetStatus added in v0.0.26 

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

func (*ImportGithubResponse) ProtoMessage added in v0.0.26 

func (*ImportGithubResponse) ProtoMessage()

func (*ImportGithubResponse) Reset added in v0.0.26 

func (m *ImportGithubResponse) Reset()

func (*ImportGithubResponse) String added in v0.0.26 

func (m *ImportGithubResponse) String() string

func (*ImportGithubResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *ImportGithubResponse) XXX_DiscardUnknown()

func (*ImportGithubResponse) XXX_Marshal added in v0.0.26 

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

func (*ImportGithubResponse) XXX_Merge added in v0.0.26 

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

func (*ImportGithubResponse) XXX_Size added in v0.0.26 

func (m *ImportGithubResponse) XXX_Size() int

func (*ImportGithubResponse) XXX_Unmarshal added in v0.0.26 

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

type ImportLocalRequest added in v0.0.26 

type ImportLocalRequest struct {
	// Every gRPC request must have a valid auth config
	Auth       *common.Auth  `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Name       string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type       encoding.Type `protobuf:"varint,2,opt,name=type,proto3,enum=protos.encoding.Type" json:"type,omitempty"`
	ZipArchive []byte        `protobuf:"bytes,3,opt,name=zip_archive,json=zipArchive,proto3" json:"zip_archive,omitempty"`
	// Protobuf only, root message name
	RootType             string   `protobuf:"bytes,4,opt,name=root_type,json=rootType,proto3" json:"root_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportLocalRequest) Descriptor added in v0.0.26 

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

func (*ImportLocalRequest) GetAuth added in v0.0.26 

func (m *ImportLocalRequest) GetAuth() *common.Auth

func (*ImportLocalRequest) GetName added in v0.0.26 

func (m *ImportLocalRequest) GetName() string

func (*ImportLocalRequest) GetRootType added in v0.0.26 

func (m *ImportLocalRequest) GetRootType() string

func (*ImportLocalRequest) GetType added in v0.0.26 

func (m *ImportLocalRequest) GetType() encoding.Type

func (*ImportLocalRequest) GetZipArchive added in v0.0.26 

func (m *ImportLocalRequest) GetZipArchive() []byte

func (*ImportLocalRequest) ProtoMessage added in v0.0.26 

func (*ImportLocalRequest) ProtoMessage()

func (*ImportLocalRequest) Reset added in v0.0.26 

func (m *ImportLocalRequest) Reset()

func (*ImportLocalRequest) String added in v0.0.26 

func (m *ImportLocalRequest) String() string

func (*ImportLocalRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *ImportLocalRequest) XXX_DiscardUnknown()

func (*ImportLocalRequest) XXX_Marshal added in v0.0.26 

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

func (*ImportLocalRequest) XXX_Merge added in v0.0.26 

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

func (*ImportLocalRequest) XXX_Size added in v0.0.26 

func (m *ImportLocalRequest) XXX_Size() int

func (*ImportLocalRequest) XXX_Unmarshal added in v0.0.26 

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

type ImportLocalResponse added in v0.0.26 

type ImportLocalResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	Id                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ImportLocalResponse) Descriptor added in v0.0.26 

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

func (*ImportLocalResponse) GetId added in v0.0.26 

func (m *ImportLocalResponse) GetId() string

func (*ImportLocalResponse) GetStatus added in v0.0.26 

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

func (*ImportLocalResponse) ProtoMessage added in v0.0.26 

func (*ImportLocalResponse) ProtoMessage()

func (*ImportLocalResponse) Reset added in v0.0.26 

func (m *ImportLocalResponse) Reset()

func (*ImportLocalResponse) String added in v0.0.26 

func (m *ImportLocalResponse) String() string

func (*ImportLocalResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *ImportLocalResponse) XXX_DiscardUnknown()

func (*ImportLocalResponse) XXX_Marshal added in v0.0.26 

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

func (*ImportLocalResponse) XXX_Merge added in v0.0.26 

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

func (*ImportLocalResponse) XXX_Size added in v0.0.26 

func (m *ImportLocalResponse) XXX_Size() int

func (*ImportLocalResponse) XXX_Unmarshal added in v0.0.26 

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

type IsGithubAuthRequest added in v0.0.25 

type IsGithubAuthRequest 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 (*IsGithubAuthRequest) Descriptor added in v0.0.25 

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

func (*IsGithubAuthRequest) GetAuth added in v0.0.25 

func (m *IsGithubAuthRequest) GetAuth() *common.Auth

func (*IsGithubAuthRequest) ProtoMessage added in v0.0.25 

func (*IsGithubAuthRequest) ProtoMessage()

func (*IsGithubAuthRequest) Reset added in v0.0.25 

func (m *IsGithubAuthRequest) Reset()

func (*IsGithubAuthRequest) String added in v0.0.25 

func (m *IsGithubAuthRequest) String() string

func (*IsGithubAuthRequest) XXX_DiscardUnknown added in v0.0.25 

func (m *IsGithubAuthRequest) XXX_DiscardUnknown()

func (*IsGithubAuthRequest) XXX_Marshal added in v0.0.25 

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

func (*IsGithubAuthRequest) XXX_Merge added in v0.0.25 

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

func (*IsGithubAuthRequest) XXX_Size added in v0.0.25 

func (m *IsGithubAuthRequest) XXX_Size() int

func (*IsGithubAuthRequest) XXX_Unmarshal added in v0.0.25 

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

type IsGithubAuthResponse added in v0.0.25 

type IsGithubAuthResponse struct {
	Authorized           bool     `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsGithubAuthResponse) Descriptor added in v0.0.25 

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

func (*IsGithubAuthResponse) GetAuthorized added in v0.0.25 

func (m *IsGithubAuthResponse) GetAuthorized() bool

func (*IsGithubAuthResponse) ProtoMessage added in v0.0.25 

func (*IsGithubAuthResponse) ProtoMessage()

func (*IsGithubAuthResponse) Reset added in v0.0.25 

func (m *IsGithubAuthResponse) Reset()

func (*IsGithubAuthResponse) String added in v0.0.25 

func (m *IsGithubAuthResponse) String() string

func (*IsGithubAuthResponse) XXX_DiscardUnknown added in v0.0.25 

func (m *IsGithubAuthResponse) XXX_DiscardUnknown()

func (*IsGithubAuthResponse) XXX_Marshal added in v0.0.25 

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

func (*IsGithubAuthResponse) XXX_Merge added in v0.0.25 

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

func (*IsGithubAuthResponse) XXX_Size added in v0.0.25 

func (m *IsGithubAuthResponse) XXX_Size() int

func (*IsGithubAuthResponse) XXX_Unmarshal added in v0.0.25 

func (m *IsGithubAuthResponse) 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
	CreateRead(ctx context.Context, in *CreateReadRequest, opts ...grpc.CallOption) (*CreateReadResponse, error)
	// Streams messages received off of a read
	StartRead(ctx context.Context, in *StartReadRequest, opts ...grpc.CallOption) (PlumberServer_StartReadClient, error)
	// List all reads that have been created
	GetAllReads(ctx context.Context, in *GetAllReadsRequest, opts ...grpc.CallOption) (*GetAllReadsResponse, error)
	// Stop reading data from a connection
	StopRead(ctx context.Context, in *StopReadRequest, opts ...grpc.CallOption) (*StopReadResponse, error)
	// Resume reading data from an existing read
	ResumeRead(ctx context.Context, in *ResumeReadRequest, opts ...grpc.CallOption) (*ResumeReadResponse, error)
	// Resume reading data from an existing read
	DeleteRead(ctx context.Context, in *DeleteReadRequest, opts ...grpc.CallOption) (*DeleteReadResponse, 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)
	ResumeRelay(ctx context.Context, in *ResumeRelayRequest, opts ...grpc.CallOption) (*ResumeRelayResponse, error)
	StopRelay(ctx context.Context, in *StopRelayRequest, opts ...grpc.CallOption) (*StopRelayResponse, error)
	GetAllRelays(ctx context.Context, in *GetAllRelaysRequest, opts ...grpc.CallOption) (*GetAllRelaysResponse, error)
	// Delete an existing relay
	DeleteRelay(ctx context.Context, in *DeleteRelayRequest, opts ...grpc.CallOption) (*DeleteRelayResponse, error)
	// Begins github authorization process
	StartGithubAuth(ctx context.Context, in *StartGithubAuthRequest, opts ...grpc.CallOption) (*StartGithubAuthResponse, error)
	// Starts a poll of the github authorization status
	PollGithubAuth(ctx context.Context, in *PollGithubAuthRequest, opts ...grpc.CallOption) (PlumberServer_PollGithubAuthClient, error)
	// Determines if we have authorized plumber with github
	IsGithubAuth(ctx context.Context, in *IsGithubAuthRequest, opts ...grpc.CallOption) (*IsGithubAuthResponse, error)
	// Retrieve a single schema
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	// Retrieve all schemas
	GetAllSchemas(ctx context.Context, in *GetAllSchemasRequest, opts ...grpc.CallOption) (*GetAllSchemasResponse, error)
	// Import a schema from github
	ImportGithub(ctx context.Context, in *ImportGithubRequest, opts ...grpc.CallOption) (*ImportGithubResponse, error)
	// Import a schema from the local file system
	ImportLocal(ctx context.Context, in *ImportLocalRequest, opts ...grpc.CallOption) (*ImportLocalResponse, error)
	// Delete a schema
	DeleteSchema(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*DeleteSchemaResponse, error)
	GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceResponse, error)
	GetAllServices(ctx context.Context, in *GetAllServicesRequest, opts ...grpc.CallOption) (*GetAllServicesResponse, error)
	CreateService(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)
	UpdateService(ctx context.Context, in *UpdateServiceRequest, opts ...grpc.CallOption) (*UpdateServiceResponse, error)
	DeleteService(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceResponse, 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
	CreateRead(context.Context, *CreateReadRequest) (*CreateReadResponse, error)
	// Streams messages received off of a read
	StartRead(*StartReadRequest, PlumberServer_StartReadServer) error
	// List all reads that have been created
	GetAllReads(context.Context, *GetAllReadsRequest) (*GetAllReadsResponse, error)
	// Stop reading data from a connection
	StopRead(context.Context, *StopReadRequest) (*StopReadResponse, error)
	// Resume reading data from an existing read
	ResumeRead(context.Context, *ResumeReadRequest) (*ResumeReadResponse, error)
	// Resume reading data from an existing read
	DeleteRead(context.Context, *DeleteReadRequest) (*DeleteReadResponse, 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)
	ResumeRelay(context.Context, *ResumeRelayRequest) (*ResumeRelayResponse, error)
	StopRelay(context.Context, *StopRelayRequest) (*StopRelayResponse, error)
	GetAllRelays(context.Context, *GetAllRelaysRequest) (*GetAllRelaysResponse, error)
	// Delete an existing relay
	DeleteRelay(context.Context, *DeleteRelayRequest) (*DeleteRelayResponse, error)
	// Begins github authorization process
	StartGithubAuth(context.Context, *StartGithubAuthRequest) (*StartGithubAuthResponse, error)
	// Starts a poll of the github authorization status
	PollGithubAuth(*PollGithubAuthRequest, PlumberServer_PollGithubAuthServer) error
	// Determines if we have authorized plumber with github
	IsGithubAuth(context.Context, *IsGithubAuthRequest) (*IsGithubAuthResponse, error)
	// Retrieve a single schema
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	// Retrieve all schemas
	GetAllSchemas(context.Context, *GetAllSchemasRequest) (*GetAllSchemasResponse, error)
	// Import a schema from github
	ImportGithub(context.Context, *ImportGithubRequest) (*ImportGithubResponse, error)
	// Import a schema from the local file system
	ImportLocal(context.Context, *ImportLocalRequest) (*ImportLocalResponse, error)
	// Delete a schema
	DeleteSchema(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error)
	GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)
	GetAllServices(context.Context, *GetAllServicesRequest) (*GetAllServicesResponse, error)
	CreateService(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
	UpdateService(context.Context, *UpdateServiceRequest) (*UpdateServiceResponse, error)
	DeleteService(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, error)
}

PlumberServerServer is the server API for PlumberServer service.

type PlumberServer_PollGithubAuthClient added in v0.0.25 

type PlumberServer_PollGithubAuthClient interface {
	Recv() (*PollGithubAuthResponse, error)
	grpc.ClientStream
}

type PlumberServer_PollGithubAuthServer added in v0.0.25 

type PlumberServer_PollGithubAuthServer interface {
	Send(*PollGithubAuthResponse) error
	grpc.ServerStream
}

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 PollGithubAuthRequest added in v0.0.25 

type PollGithubAuthRequest 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 (*PollGithubAuthRequest) Descriptor added in v0.0.25 

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

func (*PollGithubAuthRequest) GetAuth added in v0.0.25 

func (m *PollGithubAuthRequest) GetAuth() *common.Auth

func (*PollGithubAuthRequest) ProtoMessage added in v0.0.25 

func (*PollGithubAuthRequest) ProtoMessage()

func (*PollGithubAuthRequest) Reset added in v0.0.25 

func (m *PollGithubAuthRequest) Reset()

func (*PollGithubAuthRequest) String added in v0.0.25 

func (m *PollGithubAuthRequest) String() string

func (*PollGithubAuthRequest) XXX_DiscardUnknown added in v0.0.25 

func (m *PollGithubAuthRequest) XXX_DiscardUnknown()

func (*PollGithubAuthRequest) XXX_Marshal added in v0.0.25 

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

func (*PollGithubAuthRequest) XXX_Merge added in v0.0.25 

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

func (*PollGithubAuthRequest) XXX_Size added in v0.0.25 

func (m *PollGithubAuthRequest) XXX_Size() int

func (*PollGithubAuthRequest) XXX_Unmarshal added in v0.0.25 

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

type PollGithubAuthResponse added in v0.0.25 

type PollGithubAuthResponse struct {
	Status               PollGithubAuthResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=protos.PollGithubAuthResponse_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*PollGithubAuthResponse) Descriptor added in v0.0.25 

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

func (*PollGithubAuthResponse) GetStatus added in v0.0.25 

func (m *PollGithubAuthResponse) GetStatus() PollGithubAuthResponse_Status

func (*PollGithubAuthResponse) ProtoMessage added in v0.0.25 

func (*PollGithubAuthResponse) ProtoMessage()

func (*PollGithubAuthResponse) Reset added in v0.0.25 

func (m *PollGithubAuthResponse) Reset()

func (*PollGithubAuthResponse) String added in v0.0.25 

func (m *PollGithubAuthResponse) String() string

func (*PollGithubAuthResponse) XXX_DiscardUnknown added in v0.0.25 

func (m *PollGithubAuthResponse) XXX_DiscardUnknown()

func (*PollGithubAuthResponse) XXX_Marshal added in v0.0.25 

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

func (*PollGithubAuthResponse) XXX_Merge added in v0.0.25 

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

func (*PollGithubAuthResponse) XXX_Size added in v0.0.25 

func (m *PollGithubAuthResponse) XXX_Size() int

func (*PollGithubAuthResponse) XXX_Unmarshal added in v0.0.25 

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

type PollGithubAuthResponse_Status added in v0.0.25 

type PollGithubAuthResponse_Status int32
const (
	PollGithubAuthResponse_PENDING PollGithubAuthResponse_Status = 0
	PollGithubAuthResponse_SUCCESS PollGithubAuthResponse_Status = 1
	PollGithubAuthResponse_FAILED  PollGithubAuthResponse_Status = 2
)

func (PollGithubAuthResponse_Status) EnumDescriptor added in v0.0.25 

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

func (PollGithubAuthResponse_Status) String added in v0.0.25 

func (x PollGithubAuthResponse_Status) String() string

type ReadConfig added in v0.0.34 

type ReadConfig struct {
	// Automatically set by plumber when a new read is created
	XId string `protobuf:"bytes,1,opt,name=_id,json=Id,proto3" json:"_id,omitempty"`
	// Used by plumber to set read state
	XActive bool `protobuf:"varint,2,opt,name=_active,json=Active,proto3" json:"_active,omitempty"`
	// Required; friendly name for the read
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Semi-required; either set this or connection_config. If set, connection_config
	// will be ignored.
	ConnectionId string `protobuf:"bytes,4,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// Semi-required; either set this or connection_id. This is generally used
	// for creating ephemeral connections (ie. via CLI).
	ConnectionConfig *ConnectionConfig `protobuf:"bytes,5,opt,name=connection_config,json=connectionConfig,proto3" json:"connection_config,omitempty"`
	// Required; options specifying how to read data
	ReadOptions *ReadOptions `protobuf:"bytes,6,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"`
	// Optional; options specify how to decode the _value_ in a message.
	// If left unset, plumber will still populate records.ReadRecord.Decoded
	// with the (untouched) value.
	DecodeOptions *encoding.Options `protobuf:"bytes,7,opt,name=decode_options,json=decodeOptions,proto3" json:"decode_options,omitempty"`
	// Types that are valid to be assigned to Backends:
	//	*ReadConfig_Kafka
	//	*ReadConfig_ActiveMq
	//	*ReadConfig_Awssqs
	//	*ReadConfig_Awssns
	//	*ReadConfig_Mongo
	//	*ReadConfig_Nats
	//	*ReadConfig_NatsStreaming
	//	*ReadConfig_Nsq
	//	*ReadConfig_Postgres
	//	*ReadConfig_Pulsar
	//	*ReadConfig_Rabbit
	//	*ReadConfig_RabbitStreams
	//	*ReadConfig_RedisPubsub
	//	*ReadConfig_RedisStreams
	//	*ReadConfig_AzureEventHub
	//	*ReadConfig_AzureServiceBus
	Backends             isReadConfig_Backends `protobuf_oneof:"Backends"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ReadConfig) Descriptor added in v0.0.34 

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

func (*ReadConfig) GetActiveMq added in v0.0.34 

func (m *ReadConfig) GetActiveMq() *backends.ActiveMQ

func (*ReadConfig) GetAwssns added in v0.0.34 

func (m *ReadConfig) GetAwssns() *backends.AWSSNS

func (*ReadConfig) GetAwssqs added in v0.0.34 

func (m *ReadConfig) GetAwssqs() *backends.AWSSQS

func (*ReadConfig) GetAzureEventHub added in v0.0.34 

func (m *ReadConfig) GetAzureEventHub() *backends.AzureEventHub

func (*ReadConfig) GetAzureServiceBus added in v0.0.34 

func (m *ReadConfig) GetAzureServiceBus() *backends.AzureServiceBus

func (*ReadConfig) GetBackends added in v0.0.34 

func (m *ReadConfig) GetBackends() isReadConfig_Backends

func (*ReadConfig) GetConnectionConfig added in v0.0.35 

func (m *ReadConfig) GetConnectionConfig() *ConnectionConfig

func (*ReadConfig) GetConnectionId added in v0.0.34 

func (m *ReadConfig) GetConnectionId() string

func (*ReadConfig) GetDecodeOptions added in v0.0.34 

func (m *ReadConfig) GetDecodeOptions() *encoding.Options

func (*ReadConfig) GetKafka added in v0.0.34 

func (m *ReadConfig) GetKafka() *backends.Kafka

func (*ReadConfig) GetMongo added in v0.0.34 

func (m *ReadConfig) GetMongo() *backends.Mongo

func (*ReadConfig) GetName added in v0.0.34 

func (m *ReadConfig) GetName() string

func (*ReadConfig) GetNats added in v0.0.34 

func (m *ReadConfig) GetNats() *backends.Nats

func (*ReadConfig) GetNatsStreaming added in v0.0.34 

func (m *ReadConfig) GetNatsStreaming() *backends.NatsStreaming

func (*ReadConfig) GetNsq added in v0.0.34 

func (m *ReadConfig) GetNsq() *backends.NSQ

func (*ReadConfig) GetPostgres added in v0.0.34 

func (m *ReadConfig) GetPostgres() *backends.Postgres

func (*ReadConfig) GetPulsar added in v0.0.34 

func (m *ReadConfig) GetPulsar() *backends.Pulsar

func (*ReadConfig) GetRabbit added in v0.0.34 

func (m *ReadConfig) GetRabbit() *backends.Rabbit

func (*ReadConfig) GetRabbitStreams added in v0.0.34 

func (m *ReadConfig) GetRabbitStreams() *backends.RabbitStreams

func (*ReadConfig) GetReadOptions added in v0.0.34 

func (m *ReadConfig) GetReadOptions() *ReadOptions

func (*ReadConfig) GetRedisPubsub added in v0.0.34 

func (m *ReadConfig) GetRedisPubsub() *backends.RedisPubsub

func (*ReadConfig) GetRedisStreams added in v0.0.34 

func (m *ReadConfig) GetRedisStreams() *backends.RedisStreams

func (*ReadConfig) GetXActive added in v0.0.34 

func (m *ReadConfig) GetXActive() bool

func (*ReadConfig) GetXId added in v0.0.34 

func (m *ReadConfig) GetXId() string

func (*ReadConfig) ProtoMessage added in v0.0.34 

func (*ReadConfig) ProtoMessage()

func (*ReadConfig) Reset added in v0.0.34 

func (m *ReadConfig) Reset()

func (*ReadConfig) String added in v0.0.34 

func (m *ReadConfig) String() string

func (*ReadConfig) XXX_DiscardUnknown added in v0.0.34 

func (m *ReadConfig) XXX_DiscardUnknown()

func (*ReadConfig) XXX_Marshal added in v0.0.34 

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

func (*ReadConfig) XXX_Merge added in v0.0.34 

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

func (*ReadConfig) XXX_OneofWrappers added in v0.0.34 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadConfig) XXX_Size added in v0.0.34 

func (m *ReadConfig) XXX_Size() int

func (*ReadConfig) XXX_Unmarshal added in v0.0.34 

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

type ReadConfig_ActiveMq added in v0.0.34 

type ReadConfig_ActiveMq struct {
	ActiveMq *backends.ActiveMQ `protobuf:"bytes,101,opt,name=active_mq,json=activeMq,proto3,oneof"`
}

type ReadConfig_Awssns added in v0.0.34 

type ReadConfig_Awssns struct {
	Awssns *backends.AWSSNS `protobuf:"bytes,103,opt,name=awssns,proto3,oneof"`
}

type ReadConfig_Awssqs added in v0.0.34 

type ReadConfig_Awssqs struct {
	Awssqs *backends.AWSSQS `protobuf:"bytes,102,opt,name=awssqs,proto3,oneof"`
}

type ReadConfig_AzureEventHub added in v0.0.34 

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

type ReadConfig_AzureServiceBus added in v0.0.34 

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

type ReadConfig_Kafka added in v0.0.34 

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

type ReadConfig_Mongo added in v0.0.34 

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

type ReadConfig_Nats added in v0.0.34 

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

type ReadConfig_NatsStreaming added in v0.0.34 

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

type ReadConfig_Nsq added in v0.0.34 

type ReadConfig_Nsq struct {
	Nsq *backends.NSQ `protobuf:"bytes,107,opt,name=nsq,proto3,oneof"`
}

type ReadConfig_Postgres added in v0.0.34 

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

type ReadConfig_Pulsar added in v0.0.34 

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

type ReadConfig_Rabbit added in v0.0.34 

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

type ReadConfig_RabbitStreams added in v0.0.34 

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

type ReadConfig_RedisPubsub added in v0.0.34 

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

type ReadConfig_RedisStreams added in v0.0.34 

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

type ReadOptions 

type ReadOptions struct {
	SampleOptions        *SampleOptions `protobuf:"bytes,1,opt,name=sample_options,json=sampleOptions,proto3" json:"sample_options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ReadOptions) Descriptor 

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

func (*ReadOptions) GetSampleOptions added in v0.0.34 

func (m *ReadOptions) GetSampleOptions() *SampleOptions

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 RelayConfig added in v0.0.34 

type RelayConfig 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"`
	// Semi-required; either set this or connection_config. If set,
	// connection_config will be ignored.
	ConnectionId string `protobuf:"bytes,4,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// Semi-required; either set this or connection_id. This is generally used
	// for creating ephemeral connections (ie. via CLI).
	ConnectionConfig *ConnectionConfig `protobuf:"bytes,5,opt,name=connection_config,json=connectionConfig,proto3" json:"connection_config,omitempty"`
	// Optional; where to send events to (default: grpc-collector.batch.sh:9000)
	XBatchshGrpcAddress string `protobuf:"bytes,6,opt,name=_batchsh_grpc_address,json=BatchshGrpcAddress,proto3" json:"_batchsh_grpc_address,omitempty"`
	// Optional; whether to use TLS for gRPC (default: true)
	XBatchshGrpcDisableTls bool `` /* 131-byte string literal not displayed */
	// Optional: how long to wait before giving up talking to the gRPC collector (default: 10s)
	XBatchshGrpcTimeout bool `protobuf:"varint,8,opt,name=_batchsh_grpc_timeout,json=BatchshGrpcTimeout,proto3" json:"_batchsh_grpc_timeout,omitempty"`
	// ID of the created relay entry; populated by plumber.
	XRelayId string `protobuf:"bytes,9,opt,name=_relay_id,json=RelayId,proto3" json:"_relay_id,omitempty"`
	// Set appropriate backend based on what connection is specified
	// ie. If connection_id is for kafka - specify Kafka backend
	//
	// Types that are valid to be assigned to Backends:
	//	*RelayConfig_Kafka
	//	*RelayConfig_ActiveMq
	//	*RelayConfig_Awssqs
	//	*RelayConfig_Awssns
	//	*RelayConfig_Mongo
	//	*RelayConfig_Nats
	//	*RelayConfig_NatsStreaming
	//	*RelayConfig_Nsq
	//	*RelayConfig_Postgres
	//	*RelayConfig_Pulsar
	//	*RelayConfig_Rabbit
	//	*RelayConfig_RabbitStreams
	//	*RelayConfig_RedisPubsub
	//	*RelayConfig_RedisStreams
	//	*RelayConfig_AzureEventHub
	//	*RelayConfig_AzureServiceBus
	Backends             isRelayConfig_Backends `protobuf_oneof:"Backends"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*RelayConfig) Descriptor added in v0.0.34 

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

func (*RelayConfig) GetActiveMq added in v0.0.34 

func (m *RelayConfig) GetActiveMq() *backends.ActiveMQ

func (*RelayConfig) GetAwssns added in v0.0.34 

func (m *RelayConfig) GetAwssns() *backends.AWSSNS

func (*RelayConfig) GetAwssqs added in v0.0.34 

func (m *RelayConfig) GetAwssqs() *backends.AWSSQS

func (*RelayConfig) GetAzureEventHub added in v0.0.34 

func (m *RelayConfig) GetAzureEventHub() *backends.AzureEventHub

func (*RelayConfig) GetAzureServiceBus added in v0.0.34 

func (m *RelayConfig) GetAzureServiceBus() *backends.AzureServiceBus

func (*RelayConfig) GetBackends added in v0.0.34 

func (m *RelayConfig) GetBackends() isRelayConfig_Backends

func (*RelayConfig) GetBatchCollectionToken added in v0.0.34 

func (m *RelayConfig) GetBatchCollectionToken() string

func (*RelayConfig) GetBatchMaxRetry added in v0.0.34 

func (m *RelayConfig) GetBatchMaxRetry() int32

func (*RelayConfig) GetBatchSize added in v0.0.34 

func (m *RelayConfig) GetBatchSize() int32

func (*RelayConfig) GetConnectionConfig added in v0.0.35 

func (m *RelayConfig) GetConnectionConfig() *ConnectionConfig

func (*RelayConfig) GetConnectionId added in v0.0.34 

func (m *RelayConfig) GetConnectionId() string

func (*RelayConfig) GetKafka added in v0.0.34 

func (m *RelayConfig) GetKafka() *backends.Kafka

func (*RelayConfig) GetMongo added in v0.0.34 

func (m *RelayConfig) GetMongo() *backends.Mongo

func (*RelayConfig) GetNats added in v0.0.34 

func (m *RelayConfig) GetNats() *backends.Nats

func (*RelayConfig) GetNatsStreaming added in v0.0.34 

func (m *RelayConfig) GetNatsStreaming() *backends.NatsStreaming

func (*RelayConfig) GetNsq added in v0.0.34 

func (m *RelayConfig) GetNsq() *backends.NSQ

func (*RelayConfig) GetPostgres added in v0.0.34 

func (m *RelayConfig) GetPostgres() *backends.Postgres

func (*RelayConfig) GetPulsar added in v0.0.34 

func (m *RelayConfig) GetPulsar() *backends.Pulsar

func (*RelayConfig) GetRabbit added in v0.0.34 

func (m *RelayConfig) GetRabbit() *backends.Rabbit

func (*RelayConfig) GetRabbitStreams added in v0.0.34 

func (m *RelayConfig) GetRabbitStreams() *backends.RabbitStreams

func (*RelayConfig) GetRedisPubsub added in v0.0.34 

func (m *RelayConfig) GetRedisPubsub() *backends.RedisPubsub

func (*RelayConfig) GetRedisStreams added in v0.0.34 

func (m *RelayConfig) GetRedisStreams() *backends.RedisStreams

func (*RelayConfig) GetXBatchshGrpcAddress added in v0.0.37 

func (m *RelayConfig) GetXBatchshGrpcAddress() string

func (*RelayConfig) GetXBatchshGrpcDisableTls added in v0.0.37 

func (m *RelayConfig) GetXBatchshGrpcDisableTls() bool

func (*RelayConfig) GetXBatchshGrpcTimeout added in v0.0.37 

func (m *RelayConfig) GetXBatchshGrpcTimeout() bool

func (*RelayConfig) GetXRelayId added in v0.0.35 

func (m *RelayConfig) GetXRelayId() string

func (*RelayConfig) ProtoMessage added in v0.0.34 

func (*RelayConfig) ProtoMessage()

func (*RelayConfig) Reset added in v0.0.34 

func (m *RelayConfig) Reset()

func (*RelayConfig) String added in v0.0.34 

func (m *RelayConfig) String() string

func (*RelayConfig) XXX_DiscardUnknown added in v0.0.34 

func (m *RelayConfig) XXX_DiscardUnknown()

func (*RelayConfig) XXX_Marshal added in v0.0.34 

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

func (*RelayConfig) XXX_Merge added in v0.0.34 

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

func (*RelayConfig) XXX_OneofWrappers added in v0.0.34 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*RelayConfig) XXX_Size added in v0.0.34 

func (m *RelayConfig) XXX_Size() int

func (*RelayConfig) XXX_Unmarshal added in v0.0.34 

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

type RelayConfig_ActiveMq added in v0.0.34 

type RelayConfig_ActiveMq struct {
	ActiveMq *backends.ActiveMQ `protobuf:"bytes,101,opt,name=active_mq,json=activeMq,proto3,oneof"`
}

type RelayConfig_Awssns added in v0.0.34 

type RelayConfig_Awssns struct {
	Awssns *backends.AWSSNS `protobuf:"bytes,103,opt,name=awssns,proto3,oneof"`
}

type RelayConfig_Awssqs added in v0.0.34 

type RelayConfig_Awssqs struct {
	Awssqs *backends.AWSSQS `protobuf:"bytes,102,opt,name=awssqs,proto3,oneof"`
}

type RelayConfig_AzureEventHub added in v0.0.34 

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

type RelayConfig_AzureServiceBus added in v0.0.34 

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

type RelayConfig_Kafka added in v0.0.34 

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

type RelayConfig_Mongo added in v0.0.34 

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

type RelayConfig_Nats added in v0.0.34 

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

type RelayConfig_NatsStreaming added in v0.0.34 

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

type RelayConfig_Nsq added in v0.0.34 

type RelayConfig_Nsq struct {
	Nsq *backends.NSQ `protobuf:"bytes,107,opt,name=nsq,proto3,oneof"`
}

type RelayConfig_Postgres added in v0.0.34 

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

type RelayConfig_Pulsar added in v0.0.34 

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

type RelayConfig_Rabbit added in v0.0.34 

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

type RelayConfig_RabbitStreams added in v0.0.34 

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

type RelayConfig_RedisPubsub added in v0.0.34 

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

type RelayConfig_RedisStreams added in v0.0.34 

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

type ResumeReadRequest added in v0.0.20 

type ResumeReadRequest 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 (*ResumeReadRequest) Descriptor added in v0.0.20 

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

func (*ResumeReadRequest) GetAuth added in v0.0.20 

func (m *ResumeReadRequest) GetAuth() *common.Auth

func (*ResumeReadRequest) GetReadId added in v0.0.20 

func (m *ResumeReadRequest) GetReadId() string

func (*ResumeReadRequest) ProtoMessage added in v0.0.20 

func (*ResumeReadRequest) ProtoMessage()

func (*ResumeReadRequest) Reset added in v0.0.20 

func (m *ResumeReadRequest) Reset()

func (*ResumeReadRequest) String added in v0.0.20 

func (m *ResumeReadRequest) String() string

func (*ResumeReadRequest) XXX_DiscardUnknown added in v0.0.20 

func (m *ResumeReadRequest) XXX_DiscardUnknown()

func (*ResumeReadRequest) XXX_Marshal added in v0.0.20 

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

func (*ResumeReadRequest) XXX_Merge added in v0.0.20 

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

func (*ResumeReadRequest) XXX_Size added in v0.0.20 

func (m *ResumeReadRequest) XXX_Size() int

func (*ResumeReadRequest) XXX_Unmarshal added in v0.0.20 

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

type ResumeReadResponse added in v0.0.20 

type ResumeReadResponse 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 (*ResumeReadResponse) Descriptor added in v0.0.20 

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

func (*ResumeReadResponse) GetStatus added in v0.0.20 

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

func (*ResumeReadResponse) ProtoMessage added in v0.0.20 

func (*ResumeReadResponse) ProtoMessage()

func (*ResumeReadResponse) Reset added in v0.0.20 

func (m *ResumeReadResponse) Reset()

func (*ResumeReadResponse) String added in v0.0.20 

func (m *ResumeReadResponse) String() string

func (*ResumeReadResponse) XXX_DiscardUnknown added in v0.0.20 

func (m *ResumeReadResponse) XXX_DiscardUnknown()

func (*ResumeReadResponse) XXX_Marshal added in v0.0.20 

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

func (*ResumeReadResponse) XXX_Merge added in v0.0.20 

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

func (*ResumeReadResponse) XXX_Size added in v0.0.20 

func (m *ResumeReadResponse) XXX_Size() int

func (*ResumeReadResponse) XXX_Unmarshal added in v0.0.20 

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

type ResumeRelayRequest added in v0.0.16 

type ResumeRelayRequest 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:"-"`
}

Resume a paused relay

func (*ResumeRelayRequest) Descriptor added in v0.0.16 

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

func (*ResumeRelayRequest) GetAuth added in v0.0.16 

func (m *ResumeRelayRequest) GetAuth() *common.Auth

func (*ResumeRelayRequest) GetRelayId added in v0.0.16 

func (m *ResumeRelayRequest) GetRelayId() string

func (*ResumeRelayRequest) ProtoMessage added in v0.0.16 

func (*ResumeRelayRequest) ProtoMessage()

func (*ResumeRelayRequest) Reset added in v0.0.16 

func (m *ResumeRelayRequest) Reset()

func (*ResumeRelayRequest) String added in v0.0.16 

func (m *ResumeRelayRequest) String() string

func (*ResumeRelayRequest) XXX_DiscardUnknown added in v0.0.16 

func (m *ResumeRelayRequest) XXX_DiscardUnknown()

func (*ResumeRelayRequest) XXX_Marshal added in v0.0.16 

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

func (*ResumeRelayRequest) XXX_Merge added in v0.0.16 

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

func (*ResumeRelayRequest) XXX_Size added in v0.0.16 

func (m *ResumeRelayRequest) XXX_Size() int

func (*ResumeRelayRequest) XXX_Unmarshal added in v0.0.16 

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

type ResumeRelayResponse added in v0.0.16 

type ResumeRelayResponse 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 (*ResumeRelayResponse) Descriptor added in v0.0.16 

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

func (*ResumeRelayResponse) GetStatus added in v0.0.16 

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

func (*ResumeRelayResponse) ProtoMessage added in v0.0.16 

func (*ResumeRelayResponse) ProtoMessage()

func (*ResumeRelayResponse) Reset added in v0.0.16 

func (m *ResumeRelayResponse) Reset()

func (*ResumeRelayResponse) String added in v0.0.16 

func (m *ResumeRelayResponse) String() string

func (*ResumeRelayResponse) XXX_DiscardUnknown added in v0.0.16 

func (m *ResumeRelayResponse) XXX_DiscardUnknown()

func (*ResumeRelayResponse) XXX_Marshal added in v0.0.16 

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

func (*ResumeRelayResponse) XXX_Merge added in v0.0.16 

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

func (*ResumeRelayResponse) XXX_Size added in v0.0.16 

func (m *ResumeRelayResponse) XXX_Size() int

func (*ResumeRelayResponse) XXX_Unmarshal added in v0.0.16 

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

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
)

func (SampleOptions_Interval) EnumDescriptor 

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

func (SampleOptions_Interval) String 

func (x SampleOptions_Interval) String() string

type Schema added in v0.0.26 

type Schema struct {
	Id    string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name  string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type  encoding.Type     `protobuf:"varint,3,opt,name=type,proto3,enum=protos.encoding.Type" json:"type,omitempty"`
	Files map[string]string `` /* 151-byte string literal not displayed */
	// Protobuf only, root message name
	RootType string `protobuf:"bytes,5,opt,name=root_type,json=rootType,proto3" json:"root_type,omitempty"`
	// Protobuf only, root message descriptor
	MessageDescriptor    []byte   `protobuf:"bytes,6,opt,name=message_descriptor,json=messageDescriptor,proto3" json:"message_descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Schema) Descriptor added in v0.0.26 

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

func (*Schema) GetFiles added in v0.0.29 

func (m *Schema) GetFiles() map[string]string

func (*Schema) GetId added in v0.0.26 

func (m *Schema) GetId() string

func (*Schema) GetMessageDescriptor added in v0.0.26 

func (m *Schema) GetMessageDescriptor() []byte

func (*Schema) GetName added in v0.0.26 

func (m *Schema) GetName() string

func (*Schema) GetRootType added in v0.0.26 

func (m *Schema) GetRootType() string

func (*Schema) GetType added in v0.0.26 

func (m *Schema) GetType() encoding.Type

func (*Schema) ProtoMessage added in v0.0.26 

func (*Schema) ProtoMessage()

func (*Schema) Reset added in v0.0.26 

func (m *Schema) Reset()

func (*Schema) String added in v0.0.26 

func (m *Schema) String() string

func (*Schema) XXX_DiscardUnknown added in v0.0.26 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal added in v0.0.26 

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

func (*Schema) XXX_Merge added in v0.0.26 

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

func (*Schema) XXX_Size added in v0.0.26 

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal added in v0.0.26 

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

type Service added in v0.0.27 

type Service struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	RepoUrl              string   `protobuf:"bytes,3,opt,name=repo_url,json=repoUrl,proto3" json:"repo_url,omitempty"`
	Notes                string   `protobuf:"bytes,4,opt,name=notes,proto3" json:"notes,omitempty"`
	OwnerId              string   `protobuf:"bytes,5,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
	UsedSchemas          []string `protobuf:"bytes,6,rep,name=used_schemas,json=usedSchemas,proto3" json:"used_schemas,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Service) Descriptor added in v0.0.27 

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

func (*Service) GetId added in v0.0.27 

func (m *Service) GetId() string

func (*Service) GetName added in v0.0.27 

func (m *Service) GetName() string

func (*Service) GetNotes added in v0.0.27 

func (m *Service) GetNotes() string

func (*Service) GetOwnerId added in v0.0.27 

func (m *Service) GetOwnerId() string

func (*Service) GetRepoUrl added in v0.0.27 

func (m *Service) GetRepoUrl() string

func (*Service) GetUsedSchemas added in v0.0.27 

func (m *Service) GetUsedSchemas() []string

func (*Service) ProtoMessage added in v0.0.27 

func (*Service) ProtoMessage()

func (*Service) Reset added in v0.0.27 

func (m *Service) Reset()

func (*Service) String added in v0.0.27 

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown added in v0.0.27 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal added in v0.0.27 

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

func (*Service) XXX_Merge added in v0.0.27 

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

func (*Service) XXX_Size added in v0.0.27 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal added in v0.0.27 

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

type StartGithubAuthRequest added in v0.0.25 

type StartGithubAuthRequest 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 (*StartGithubAuthRequest) Descriptor added in v0.0.25 

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

func (*StartGithubAuthRequest) GetAuth added in v0.0.25 

func (m *StartGithubAuthRequest) GetAuth() *common.Auth

func (*StartGithubAuthRequest) ProtoMessage added in v0.0.25 

func (*StartGithubAuthRequest) ProtoMessage()

func (*StartGithubAuthRequest) Reset added in v0.0.25 

func (m *StartGithubAuthRequest) Reset()

func (*StartGithubAuthRequest) String added in v0.0.25 

func (m *StartGithubAuthRequest) String() string

func (*StartGithubAuthRequest) XXX_DiscardUnknown added in v0.0.25 

func (m *StartGithubAuthRequest) XXX_DiscardUnknown()

func (*StartGithubAuthRequest) XXX_Marshal added in v0.0.25 

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

func (*StartGithubAuthRequest) XXX_Merge added in v0.0.25 

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

func (*StartGithubAuthRequest) XXX_Size added in v0.0.25 

func (m *StartGithubAuthRequest) XXX_Size() int

func (*StartGithubAuthRequest) XXX_Unmarshal added in v0.0.25 

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

type StartGithubAuthResponse added in v0.0.25 

type StartGithubAuthResponse struct {
	// Authorization code that the user needs to enter on github's website
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// URL that the user needs to visit to enter the code
	VerificationUrl string `protobuf:"bytes,2,opt,name=verification_url,json=verificationUrl,proto3" json:"verification_url,omitempty"`
	// Time deadline by which the user must enter the code before a new one must
	// be generated
	EnterBefore          string   `protobuf:"bytes,3,opt,name=enter_before,json=enterBefore,proto3" json:"enter_before,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartGithubAuthResponse) Descriptor added in v0.0.25 

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

func (*StartGithubAuthResponse) GetCode added in v0.0.25 

func (m *StartGithubAuthResponse) GetCode() string

func (*StartGithubAuthResponse) GetEnterBefore added in v0.0.25 

func (m *StartGithubAuthResponse) GetEnterBefore() string

func (*StartGithubAuthResponse) GetVerificationUrl added in v0.0.25 

func (m *StartGithubAuthResponse) GetVerificationUrl() string

func (*StartGithubAuthResponse) ProtoMessage added in v0.0.25 

func (*StartGithubAuthResponse) ProtoMessage()

func (*StartGithubAuthResponse) Reset added in v0.0.25 

func (m *StartGithubAuthResponse) Reset()

func (*StartGithubAuthResponse) String added in v0.0.25 

func (m *StartGithubAuthResponse) String() string

func (*StartGithubAuthResponse) XXX_DiscardUnknown added in v0.0.25 

func (m *StartGithubAuthResponse) XXX_DiscardUnknown()

func (*StartGithubAuthResponse) XXX_Marshal added in v0.0.25 

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

func (*StartGithubAuthResponse) XXX_Merge added in v0.0.25 

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

func (*StartGithubAuthResponse) XXX_Size added in v0.0.25 

func (m *StartGithubAuthResponse) XXX_Size() int

func (*StartGithubAuthResponse) XXX_Unmarshal added in v0.0.25 

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

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

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

func (*StartReadRequest) GetAuth 

func (m *StartReadRequest) GetAuth() *common.Auth

func (*StartReadRequest) GetReadId added in v0.0.20 

func (m *StartReadRequest) GetReadId() string

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_Size 

func (m *StartReadRequest) XXX_Size() int

func (*StartReadRequest) XXX_Unmarshal 

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

type StartReadResponse 

type StartReadResponse struct {
	Records              []*records.ReadRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,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 (*StartReadResponse) Descriptor 

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

func (*StartReadResponse) GetRecords added in v0.0.33 

func (m *StartReadResponse) GetRecords() []*records.ReadRecord

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"`
	Config               *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,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) GetConfig added in v0.0.35 

func (m *TestConnectionRequest) GetConfig() *ConnectionConfig

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) CreateRead added in v0.0.20 

func (*UnimplementedPlumberServerServer) CreateRead(ctx context.Context, req *CreateReadRequest) (*CreateReadResponse, error)

func (*UnimplementedPlumberServerServer) CreateRelay 

func (*UnimplementedPlumberServerServer) CreateRelay(ctx context.Context, req *CreateRelayRequest) (*CreateRelayResponse, error)

func (*UnimplementedPlumberServerServer) CreateService added in v0.0.27 

func (*UnimplementedPlumberServerServer) CreateService(ctx context.Context, req *CreateServiceRequest) (*CreateServiceResponse, error)

func (*UnimplementedPlumberServerServer) DeleteConnection 

func (*UnimplementedPlumberServerServer) DeleteConnection(ctx context.Context, req *DeleteConnectionRequest) (*DeleteConnectionResponse, error)

func (*UnimplementedPlumberServerServer) DeleteRead added in v0.0.20 

func (*UnimplementedPlumberServerServer) DeleteRead(ctx context.Context, req *DeleteReadRequest) (*DeleteReadResponse, error)

func (*UnimplementedPlumberServerServer) DeleteRelay 

func (*UnimplementedPlumberServerServer) DeleteRelay(ctx context.Context, req *DeleteRelayRequest) (*DeleteRelayResponse, error)

func (*UnimplementedPlumberServerServer) DeleteSchema added in v0.0.26 

func (*UnimplementedPlumberServerServer) DeleteSchema(ctx context.Context, req *DeleteSchemaRequest) (*DeleteSchemaResponse, error)

func (*UnimplementedPlumberServerServer) DeleteService added in v0.0.27 

func (*UnimplementedPlumberServerServer) DeleteService(ctx context.Context, req *DeleteServiceRequest) (*DeleteServiceResponse, error)

func (*UnimplementedPlumberServerServer) GetAllConnections 

func (*UnimplementedPlumberServerServer) GetAllConnections(ctx context.Context, req *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error)

func (*UnimplementedPlumberServerServer) GetAllReads added in v0.0.18 

func (*UnimplementedPlumberServerServer) GetAllReads(ctx context.Context, req *GetAllReadsRequest) (*GetAllReadsResponse, error)

func (*UnimplementedPlumberServerServer) GetAllRelays added in v0.0.17 

func (*UnimplementedPlumberServerServer) GetAllRelays(ctx context.Context, req *GetAllRelaysRequest) (*GetAllRelaysResponse, error)

func (*UnimplementedPlumberServerServer) GetAllSchemas added in v0.0.26 

func (*UnimplementedPlumberServerServer) GetAllSchemas(ctx context.Context, req *GetAllSchemasRequest) (*GetAllSchemasResponse, error)

func (*UnimplementedPlumberServerServer) GetAllServices added in v0.0.27 

func (*UnimplementedPlumberServerServer) GetAllServices(ctx context.Context, req *GetAllServicesRequest) (*GetAllServicesResponse, error)

func (*UnimplementedPlumberServerServer) GetConnection added in v0.0.3 

func (*UnimplementedPlumberServerServer) GetConnection(ctx context.Context, req *GetConnectionRequest) (*GetConnectionResponse, error)

func (*UnimplementedPlumberServerServer) GetSchema added in v0.0.26 

func (*UnimplementedPlumberServerServer) GetSchema(ctx context.Context, req *GetSchemaRequest) (*GetSchemaResponse, error)

func (*UnimplementedPlumberServerServer) GetService added in v0.0.27 

func (*UnimplementedPlumberServerServer) GetService(ctx context.Context, req *GetServiceRequest) (*GetServiceResponse, error)

func (*UnimplementedPlumberServerServer) ImportGithub added in v0.0.26 

func (*UnimplementedPlumberServerServer) ImportGithub(ctx context.Context, req *ImportGithubRequest) (*ImportGithubResponse, error)

func (*UnimplementedPlumberServerServer) ImportLocal added in v0.0.26 

func (*UnimplementedPlumberServerServer) ImportLocal(ctx context.Context, req *ImportLocalRequest) (*ImportLocalResponse, error)

func (*UnimplementedPlumberServerServer) IsGithubAuth added in v0.0.25 

func (*UnimplementedPlumberServerServer) IsGithubAuth(ctx context.Context, req *IsGithubAuthRequest) (*IsGithubAuthResponse, error)

func (*UnimplementedPlumberServerServer) PollGithubAuth added in v0.0.25 

func (*UnimplementedPlumberServerServer) PollGithubAuth(req *PollGithubAuthRequest, srv PlumberServer_PollGithubAuthServer) error

func (*UnimplementedPlumberServerServer) ResumeRead added in v0.0.20 

func (*UnimplementedPlumberServerServer) ResumeRead(ctx context.Context, req *ResumeReadRequest) (*ResumeReadResponse, error)

func (*UnimplementedPlumberServerServer) ResumeRelay added in v0.0.16 

func (*UnimplementedPlumberServerServer) ResumeRelay(ctx context.Context, req *ResumeRelayRequest) (*ResumeRelayResponse, error)

func (*UnimplementedPlumberServerServer) StartGithubAuth added in v0.0.25 

func (*UnimplementedPlumberServerServer) StartGithubAuth(ctx context.Context, req *StartGithubAuthRequest) (*StartGithubAuthResponse, 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) UpdateService added in v0.0.27 

func (*UnimplementedPlumberServerServer) UpdateService(ctx context.Context, req *UpdateServiceRequest) (*UpdateServiceResponse, 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"`
	Config               *ConnectionConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,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) GetConfig added in v0.0.35 

func (m *UpdateConnectionRequest) GetConfig() *ConnectionConfig

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"`
	Config               *RelayConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,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) GetConfig added in v0.0.34 

func (m *UpdateRelayRequest) GetConfig() *RelayConfig

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 UpdateServiceRequest added in v0.0.27 

type UpdateServiceRequest struct {
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Service              *Service     `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*UpdateServiceRequest) Descriptor added in v0.0.27 

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

func (*UpdateServiceRequest) GetAuth added in v0.0.27 

func (m *UpdateServiceRequest) GetAuth() *common.Auth

func (*UpdateServiceRequest) GetService added in v0.0.27 

func (m *UpdateServiceRequest) GetService() *Service

func (*UpdateServiceRequest) ProtoMessage added in v0.0.27 

func (*UpdateServiceRequest) ProtoMessage()

func (*UpdateServiceRequest) Reset added in v0.0.27 

func (m *UpdateServiceRequest) Reset()

func (*UpdateServiceRequest) String added in v0.0.27 

func (m *UpdateServiceRequest) String() string

func (*UpdateServiceRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *UpdateServiceRequest) XXX_DiscardUnknown()

func (*UpdateServiceRequest) XXX_Marshal added in v0.0.27 

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

func (*UpdateServiceRequest) XXX_Merge added in v0.0.27 

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

func (*UpdateServiceRequest) XXX_Size added in v0.0.27 

func (m *UpdateServiceRequest) XXX_Size() int

func (*UpdateServiceRequest) XXX_Unmarshal added in v0.0.27 

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

type UpdateServiceResponse added in v0.0.27 

type UpdateServiceResponse struct {
	Service              *Service       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,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 (*UpdateServiceResponse) Descriptor added in v0.0.27 

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

func (*UpdateServiceResponse) GetService added in v0.0.27 

func (m *UpdateServiceResponse) GetService() *Service

func (*UpdateServiceResponse) GetStatus added in v0.0.27 

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

func (*UpdateServiceResponse) ProtoMessage added in v0.0.27 

func (*UpdateServiceResponse) ProtoMessage()

func (*UpdateServiceResponse) Reset added in v0.0.27 

func (m *UpdateServiceResponse) Reset()

func (*UpdateServiceResponse) String added in v0.0.27 

func (m *UpdateServiceResponse) String() string

func (*UpdateServiceResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *UpdateServiceResponse) XXX_DiscardUnknown()

func (*UpdateServiceResponse) XXX_Marshal added in v0.0.27 

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

func (*UpdateServiceResponse) XXX_Merge added in v0.0.27 

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

func (*UpdateServiceResponse) XXX_Size added in v0.0.27 

func (m *UpdateServiceResponse) XXX_Size() int

func (*UpdateServiceResponse) XXX_Unmarshal added in v0.0.27 

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

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"`
	// Semi-required; either set this or connection_config. If set, connection_config
	// will be ignored.
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// Semi-required; either set this or connection_id. This is generally used
	// for creating ephemeral connections (ie. via CLI).
	ConnectionConfig *ConnectionConfig `protobuf:"bytes,2,opt,name=connection_config,json=connectionConfig,proto3" json:"connection_config,omitempty"`
	// We need to use a WriteRecord as a wrapper since there is no way to "repeated oneof ..."
	Records []*records.WriteRecord `protobuf:"bytes,3,rep,name=records,proto3" json:"records,omitempty"`
	// Specifying encoding options will cause the _value_ of the record to get
	// encoded and set in WriteRecord.encoded.
	EncodeOptions        *encoding.Options `protobuf:"bytes,4,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) GetConnectionConfig added in v0.0.35 

func (m *WriteRequest) GetConnectionConfig() *ConnectionConfig

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() []*records.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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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