protos

package
v0.0.140 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2022 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPlumberServerServer 

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

Types

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"`
	Options              *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,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) GetOptions added in v0.0.49 

func (m *CreateConnectionRequest) GetOptions() *opts.ConnectionOptions

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 CreateDynamicRequest added in v0.0.130 

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

func (*CreateDynamicRequest) Descriptor added in v0.0.130 

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

func (*CreateDynamicRequest) GetAuth added in v0.0.130 

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

func (*CreateDynamicRequest) GetOpts added in v0.0.130 

func (m *CreateDynamicRequest) GetOpts() *opts.DynamicOptions

func (*CreateDynamicRequest) ProtoMessage added in v0.0.130 

func (*CreateDynamicRequest) ProtoMessage()

func (*CreateDynamicRequest) Reset added in v0.0.130 

func (m *CreateDynamicRequest) Reset()

func (*CreateDynamicRequest) String added in v0.0.130 

func (m *CreateDynamicRequest) String() string

func (*CreateDynamicRequest) XXX_DiscardUnknown added in v0.0.130 

func (m *CreateDynamicRequest) XXX_DiscardUnknown()

func (*CreateDynamicRequest) XXX_Marshal added in v0.0.130 

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

func (*CreateDynamicRequest) XXX_Merge added in v0.0.130 

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

func (*CreateDynamicRequest) XXX_Size added in v0.0.130 

func (m *CreateDynamicRequest) XXX_Size() int

func (*CreateDynamicRequest) XXX_Unmarshal added in v0.0.130 

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

type CreateDynamicResponse added in v0.0.130 

type CreateDynamicResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// ID of the created dynamic destination entry
	DynamicId            string   `protobuf:"bytes,1,opt,name=dynamic_id,json=dynamicId,proto3" json:"dynamic_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDynamicResponse) Descriptor added in v0.0.130 

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

func (*CreateDynamicResponse) GetDynamicId added in v0.0.130 

func (m *CreateDynamicResponse) GetDynamicId() string

func (*CreateDynamicResponse) GetStatus added in v0.0.130 

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

func (*CreateDynamicResponse) ProtoMessage added in v0.0.130 

func (*CreateDynamicResponse) ProtoMessage()

func (*CreateDynamicResponse) Reset added in v0.0.130 

func (m *CreateDynamicResponse) Reset()

func (*CreateDynamicResponse) String added in v0.0.130 

func (m *CreateDynamicResponse) String() string

func (*CreateDynamicResponse) XXX_DiscardUnknown added in v0.0.130 

func (m *CreateDynamicResponse) XXX_DiscardUnknown()

func (*CreateDynamicResponse) XXX_Marshal added in v0.0.130 

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

func (*CreateDynamicResponse) XXX_Merge added in v0.0.130 

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

func (*CreateDynamicResponse) XXX_Size added in v0.0.130 

func (m *CreateDynamicResponse) XXX_Size() int

func (*CreateDynamicResponse) XXX_Unmarshal added in v0.0.130 

func (m *CreateDynamicResponse) 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"`
	Opts                 *opts.RelayOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*CreateRelayRequest) Descriptor 

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

func (*CreateRelayRequest) GetAuth 

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

func (*CreateRelayRequest) GetOpts added in v0.0.49 

func (m *CreateRelayRequest) GetOpts() *opts.RelayOptions

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_Size 

func (m *CreateRelayRequest) XXX_Size() int

func (*CreateRelayRequest) XXX_Unmarshal 

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

type CreateRelayResponse 

type CreateRelayResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// ID of the created relay entry
	RelayId              string   `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRelayResponse) Descriptor 

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

func (*CreateRelayResponse) GetRelayId 

func (m *CreateRelayResponse) GetRelayId() string

func (*CreateRelayResponse) GetStatus 

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

func (*CreateRelayResponse) ProtoMessage 

func (*CreateRelayResponse) ProtoMessage()

func (*CreateRelayResponse) Reset 

func (m *CreateRelayResponse) Reset()

func (*CreateRelayResponse) String 

func (m *CreateRelayResponse) String() string

func (*CreateRelayResponse) XXX_DiscardUnknown 

func (m *CreateRelayResponse) XXX_DiscardUnknown()

func (*CreateRelayResponse) XXX_Marshal 

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

func (*CreateRelayResponse) XXX_Merge 

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

func (*CreateRelayResponse) XXX_Size 

func (m *CreateRelayResponse) XXX_Size() int

func (*CreateRelayResponse) XXX_Unmarshal 

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

type DeleteConnectionRequest 

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

func (*DeleteConnectionRequest) Descriptor 

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

func (*DeleteConnectionRequest) GetAuth 

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

func (*DeleteConnectionRequest) GetConnectionId 

func (m *DeleteConnectionRequest) GetConnectionId() string

func (*DeleteConnectionRequest) ProtoMessage 

func (*DeleteConnectionRequest) ProtoMessage()

func (*DeleteConnectionRequest) Reset 

func (m *DeleteConnectionRequest) Reset()

func (*DeleteConnectionRequest) String 

func (m *DeleteConnectionRequest) String() string

func (*DeleteConnectionRequest) XXX_DiscardUnknown 

func (m *DeleteConnectionRequest) XXX_DiscardUnknown()

func (*DeleteConnectionRequest) XXX_Marshal 

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

func (*DeleteConnectionRequest) XXX_Merge 

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

func (*DeleteConnectionRequest) XXX_Size 

func (m *DeleteConnectionRequest) XXX_Size() int

func (*DeleteConnectionRequest) XXX_Unmarshal 

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

type DeleteConnectionResponse 

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

func (*DeleteConnectionResponse) Descriptor 

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

func (*DeleteConnectionResponse) GetStatus 

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

func (*DeleteConnectionResponse) ProtoMessage 

func (*DeleteConnectionResponse) ProtoMessage()

func (*DeleteConnectionResponse) Reset 

func (m *DeleteConnectionResponse) Reset()

func (*DeleteConnectionResponse) String 

func (m *DeleteConnectionResponse) String() string

func (*DeleteConnectionResponse) XXX_DiscardUnknown 

func (m *DeleteConnectionResponse) XXX_DiscardUnknown()

func (*DeleteConnectionResponse) XXX_Marshal 

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

func (*DeleteConnectionResponse) XXX_Merge 

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

func (*DeleteConnectionResponse) XXX_Size 

func (m *DeleteConnectionResponse) XXX_Size() int

func (*DeleteConnectionResponse) XXX_Unmarshal 

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

type DeleteDynamicRequest added in v0.0.130 

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

func (*DeleteDynamicRequest) Descriptor added in v0.0.130 

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

func (*DeleteDynamicRequest) GetAuth added in v0.0.130 

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

func (*DeleteDynamicRequest) GetDynamicId added in v0.0.130 

func (m *DeleteDynamicRequest) GetDynamicId() string

func (*DeleteDynamicRequest) ProtoMessage added in v0.0.130 

func (*DeleteDynamicRequest) ProtoMessage()

func (*DeleteDynamicRequest) Reset added in v0.0.130 

func (m *DeleteDynamicRequest) Reset()

func (*DeleteDynamicRequest) String added in v0.0.130 

func (m *DeleteDynamicRequest) String() string

func (*DeleteDynamicRequest) XXX_DiscardUnknown added in v0.0.130 

func (m *DeleteDynamicRequest) XXX_DiscardUnknown()

func (*DeleteDynamicRequest) XXX_Marshal added in v0.0.130 

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

func (*DeleteDynamicRequest) XXX_Merge added in v0.0.130 

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

func (*DeleteDynamicRequest) XXX_Size added in v0.0.130 

func (m *DeleteDynamicRequest) XXX_Size() int

func (*DeleteDynamicRequest) XXX_Unmarshal added in v0.0.130 

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

type DeleteDynamicResponse added in v0.0.130 

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

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

func (*DeleteDynamicResponse) GetStatus added in v0.0.130 

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

func (*DeleteDynamicResponse) ProtoMessage added in v0.0.130 

func (*DeleteDynamicResponse) ProtoMessage()

func (*DeleteDynamicResponse) Reset added in v0.0.130 

func (m *DeleteDynamicResponse) Reset()

func (*DeleteDynamicResponse) String added in v0.0.130 

func (m *DeleteDynamicResponse) String() string

func (*DeleteDynamicResponse) XXX_DiscardUnknown added in v0.0.130 

func (m *DeleteDynamicResponse) XXX_DiscardUnknown()

func (*DeleteDynamicResponse) XXX_Marshal added in v0.0.130 

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

func (*DeleteDynamicResponse) XXX_Merge added in v0.0.130 

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

func (*DeleteDynamicResponse) XXX_Size added in v0.0.130 

func (m *DeleteDynamicResponse) XXX_Size() int

func (*DeleteDynamicResponse) XXX_Unmarshal added in v0.0.130 

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

type DeleteRelayRequest 

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

func (*DeleteRelayRequest) Descriptor 

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

func (*DeleteRelayRequest) GetAuth 

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

func (*DeleteRelayRequest) GetRelayId 

func (m *DeleteRelayRequest) GetRelayId() string

func (*DeleteRelayRequest) ProtoMessage 

func (*DeleteRelayRequest) ProtoMessage()

func (*DeleteRelayRequest) Reset 

func (m *DeleteRelayRequest) Reset()

func (*DeleteRelayRequest) String 

func (m *DeleteRelayRequest) String() string

func (*DeleteRelayRequest) XXX_DiscardUnknown 

func (m *DeleteRelayRequest) XXX_DiscardUnknown()

func (*DeleteRelayRequest) XXX_Marshal 

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

func (*DeleteRelayRequest) XXX_Merge 

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

func (*DeleteRelayRequest) XXX_Size 

func (m *DeleteRelayRequest) XXX_Size() int

func (*DeleteRelayRequest) XXX_Unmarshal 

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

type DeleteRelayResponse 

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

func (*DeleteRelayResponse) Descriptor 

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

func (*DeleteRelayResponse) GetStatus 

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

func (*DeleteRelayResponse) ProtoMessage 

func (*DeleteRelayResponse) ProtoMessage()

func (*DeleteRelayResponse) Reset 

func (m *DeleteRelayResponse) Reset()

func (*DeleteRelayResponse) String 

func (m *DeleteRelayResponse) String() string

func (*DeleteRelayResponse) XXX_DiscardUnknown 

func (m *DeleteRelayResponse) XXX_DiscardUnknown()

func (*DeleteRelayResponse) XXX_Marshal 

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

func (*DeleteRelayResponse) XXX_Merge 

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

func (*DeleteRelayResponse) XXX_Size 

func (m *DeleteRelayResponse) XXX_Size() int

func (*DeleteRelayResponse) XXX_Unmarshal 

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

type GetAllConnectionsRequest 

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

func (*GetAllConnectionsRequest) Descriptor 

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

func (*GetAllConnectionsRequest) GetAuth 

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

func (*GetAllConnectionsRequest) ProtoMessage 

func (*GetAllConnectionsRequest) ProtoMessage()

func (*GetAllConnectionsRequest) Reset 

func (m *GetAllConnectionsRequest) Reset()

func (*GetAllConnectionsRequest) String 

func (m *GetAllConnectionsRequest) String() string

func (*GetAllConnectionsRequest) XXX_DiscardUnknown 

func (m *GetAllConnectionsRequest) XXX_DiscardUnknown()

func (*GetAllConnectionsRequest) XXX_Marshal 

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

func (*GetAllConnectionsRequest) XXX_Merge 

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

func (*GetAllConnectionsRequest) XXX_Size 

func (m *GetAllConnectionsRequest) XXX_Size() int

func (*GetAllConnectionsRequest) XXX_Unmarshal 

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

type GetAllConnectionsResponse 

type GetAllConnectionsResponse struct {
	Options              []*opts.ConnectionOptions `protobuf:"bytes,1,rep,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*GetAllConnectionsResponse) Descriptor 

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

func (*GetAllConnectionsResponse) GetOptions added in v0.0.49 

func (m *GetAllConnectionsResponse) GetOptions() []*opts.ConnectionOptions

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 GetAllDynamicRequest added in v0.0.130 

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

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

func (*GetAllDynamicRequest) GetAuth added in v0.0.130 

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

func (*GetAllDynamicRequest) ProtoMessage added in v0.0.130 

func (*GetAllDynamicRequest) ProtoMessage()

func (*GetAllDynamicRequest) Reset added in v0.0.130 

func (m *GetAllDynamicRequest) Reset()

func (*GetAllDynamicRequest) String added in v0.0.130 

func (m *GetAllDynamicRequest) String() string

func (*GetAllDynamicRequest) XXX_DiscardUnknown added in v0.0.130 

func (m *GetAllDynamicRequest) XXX_DiscardUnknown()

func (*GetAllDynamicRequest) XXX_Marshal added in v0.0.130 

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

func (*GetAllDynamicRequest) XXX_Merge added in v0.0.130 

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

func (*GetAllDynamicRequest) XXX_Size added in v0.0.130 

func (m *GetAllDynamicRequest) XXX_Size() int

func (*GetAllDynamicRequest) XXX_Unmarshal added in v0.0.130 

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

type GetAllDynamicResponse added in v0.0.130 

type GetAllDynamicResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// Will be set as empty []Dynamic if no dynamic destinations are configured
	Opts                 []*opts.DynamicOptions `protobuf:"bytes,1,rep,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GetAllDynamicResponse) Descriptor added in v0.0.130 

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

func (*GetAllDynamicResponse) GetOpts added in v0.0.130 

func (m *GetAllDynamicResponse) GetOpts() []*opts.DynamicOptions

func (*GetAllDynamicResponse) GetStatus added in v0.0.130 

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

func (*GetAllDynamicResponse) ProtoMessage added in v0.0.130 

func (*GetAllDynamicResponse) ProtoMessage()

func (*GetAllDynamicResponse) Reset added in v0.0.130 

func (m *GetAllDynamicResponse) Reset()

func (*GetAllDynamicResponse) String added in v0.0.130 

func (m *GetAllDynamicResponse) String() string

func (*GetAllDynamicResponse) XXX_DiscardUnknown added in v0.0.130 

func (m *GetAllDynamicResponse) XXX_DiscardUnknown()

func (*GetAllDynamicResponse) XXX_Marshal added in v0.0.130 

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

func (*GetAllDynamicResponse) XXX_Merge added in v0.0.130 

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

func (*GetAllDynamicResponse) XXX_Size added in v0.0.130 

func (m *GetAllDynamicResponse) XXX_Size() int

func (*GetAllDynamicResponse) XXX_Unmarshal added in v0.0.130 

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

func (*GetAllRelaysResponse) Descriptor 

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

func (*GetAllRelaysResponse) GetOpts added in v0.0.49 

func (m *GetAllRelaysResponse) GetOpts() []*opts.RelayOptions

func (*GetAllRelaysResponse) GetStatus 

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

func (*GetAllRelaysResponse) ProtoMessage 

func (*GetAllRelaysResponse) ProtoMessage()

func (*GetAllRelaysResponse) Reset 

func (m *GetAllRelaysResponse) Reset()

func (*GetAllRelaysResponse) String 

func (m *GetAllRelaysResponse) String() string

func (*GetAllRelaysResponse) XXX_DiscardUnknown 

func (m *GetAllRelaysResponse) XXX_DiscardUnknown()

func (*GetAllRelaysResponse) XXX_Marshal 

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

func (*GetAllRelaysResponse) XXX_Merge 

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

func (*GetAllRelaysResponse) XXX_Size 

func (m *GetAllRelaysResponse) XXX_Size() int

func (*GetAllRelaysResponse) XXX_Unmarshal 

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

type GetConnectionRequest 

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

func (*GetConnectionRequest) Descriptor 

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

func (*GetConnectionRequest) GetAuth 

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

func (*GetConnectionRequest) GetConnectionId 

func (m *GetConnectionRequest) GetConnectionId() string

func (*GetConnectionRequest) ProtoMessage 

func (*GetConnectionRequest) ProtoMessage()

func (*GetConnectionRequest) Reset 

func (m *GetConnectionRequest) Reset()

func (*GetConnectionRequest) String 

func (m *GetConnectionRequest) String() string

func (*GetConnectionRequest) XXX_DiscardUnknown 

func (m *GetConnectionRequest) XXX_DiscardUnknown()

func (*GetConnectionRequest) XXX_Marshal 

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

func (*GetConnectionRequest) XXX_Merge 

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

func (*GetConnectionRequest) XXX_Size 

func (m *GetConnectionRequest) XXX_Size() int

func (*GetConnectionRequest) XXX_Unmarshal 

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

type GetConnectionResponse 

type GetConnectionResponse struct {
	Options              *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*GetConnectionResponse) Descriptor 

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

func (*GetConnectionResponse) GetOptions added in v0.0.49 

func (m *GetConnectionResponse) GetOptions() *opts.ConnectionOptions

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 GetDynamicRequest added in v0.0.130 

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

func (*GetDynamicRequest) Descriptor added in v0.0.130 

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

func (*GetDynamicRequest) GetAuth added in v0.0.130 

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

func (*GetDynamicRequest) GetDynamicId added in v0.0.130 

func (m *GetDynamicRequest) GetDynamicId() string

func (*GetDynamicRequest) ProtoMessage added in v0.0.130 

func (*GetDynamicRequest) ProtoMessage()

func (*GetDynamicRequest) Reset added in v0.0.130 

func (m *GetDynamicRequest) Reset()

func (*GetDynamicRequest) String added in v0.0.130 

func (m *GetDynamicRequest) String() string

func (*GetDynamicRequest) XXX_DiscardUnknown added in v0.0.130 

func (m *GetDynamicRequest) XXX_DiscardUnknown()

func (*GetDynamicRequest) XXX_Marshal added in v0.0.130 

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

func (*GetDynamicRequest) XXX_Merge added in v0.0.130 

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

func (*GetDynamicRequest) XXX_Size added in v0.0.130 

func (m *GetDynamicRequest) XXX_Size() int

func (*GetDynamicRequest) XXX_Unmarshal added in v0.0.130 

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

type GetDynamicResponse added in v0.0.130 

type GetDynamicResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// Set only if status is OK
	Opts                 *opts.DynamicOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*GetDynamicResponse) Descriptor added in v0.0.130 

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

func (*GetDynamicResponse) GetOpts added in v0.0.130 

func (m *GetDynamicResponse) GetOpts() *opts.DynamicOptions

func (*GetDynamicResponse) GetStatus added in v0.0.130 

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

func (*GetDynamicResponse) ProtoMessage added in v0.0.130 

func (*GetDynamicResponse) ProtoMessage()

func (*GetDynamicResponse) Reset added in v0.0.130 

func (m *GetDynamicResponse) Reset()

func (*GetDynamicResponse) String added in v0.0.130 

func (m *GetDynamicResponse) String() string

func (*GetDynamicResponse) XXX_DiscardUnknown added in v0.0.130 

func (m *GetDynamicResponse) XXX_DiscardUnknown()

func (*GetDynamicResponse) XXX_Marshal added in v0.0.130 

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

func (*GetDynamicResponse) XXX_Merge added in v0.0.130 

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

func (*GetDynamicResponse) XXX_Size added in v0.0.130 

func (m *GetDynamicResponse) XXX_Size() int

func (*GetDynamicResponse) XXX_Unmarshal added in v0.0.130 

func (m *GetDynamicResponse) 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
	Opts                 *opts.RelayOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetRelayResponse) Descriptor 

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

func (*GetRelayResponse) GetOpts added in v0.0.49 

func (m *GetRelayResponse) GetOpts() *opts.RelayOptions

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 GetServerOptionsRequest added in v0.0.49 

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

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

func (*GetServerOptionsRequest) GetAuth added in v0.0.49 

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

func (*GetServerOptionsRequest) ProtoMessage added in v0.0.49 

func (*GetServerOptionsRequest) ProtoMessage()

func (*GetServerOptionsRequest) Reset added in v0.0.49 

func (m *GetServerOptionsRequest) Reset()

func (*GetServerOptionsRequest) String added in v0.0.49 

func (m *GetServerOptionsRequest) String() string

func (*GetServerOptionsRequest) XXX_DiscardUnknown added in v0.0.49 

func (m *GetServerOptionsRequest) XXX_DiscardUnknown()

func (*GetServerOptionsRequest) XXX_Marshal added in v0.0.49 

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

func (*GetServerOptionsRequest) XXX_Merge added in v0.0.49 

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

func (*GetServerOptionsRequest) XXX_Size added in v0.0.49 

func (m *GetServerOptionsRequest) XXX_Size() int

func (*GetServerOptionsRequest) XXX_Unmarshal added in v0.0.49 

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

type GetServerOptionsResponse added in v0.0.49 

type GetServerOptionsResponse struct {
	ServerOptions        *opts.ServerOptions `protobuf:"bytes,1,opt,name=server_options,json=serverOptions,proto3" json:"server_options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetServerOptionsResponse) Descriptor added in v0.0.49 

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

func (*GetServerOptionsResponse) GetServerOptions added in v0.0.49 

func (m *GetServerOptionsResponse) GetServerOptions() *opts.ServerOptions

func (*GetServerOptionsResponse) ProtoMessage added in v0.0.49 

func (*GetServerOptionsResponse) ProtoMessage()

func (*GetServerOptionsResponse) Reset added in v0.0.49 

func (m *GetServerOptionsResponse) Reset()

func (*GetServerOptionsResponse) String added in v0.0.49 

func (m *GetServerOptionsResponse) String() string

func (*GetServerOptionsResponse) XXX_DiscardUnknown added in v0.0.49 

func (m *GetServerOptionsResponse) XXX_DiscardUnknown()

func (*GetServerOptionsResponse) XXX_Marshal added in v0.0.49 

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

func (*GetServerOptionsResponse) XXX_Merge added in v0.0.49 

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

func (*GetServerOptionsResponse) XXX_Size added in v0.0.49 

func (m *GetServerOptionsResponse) XXX_Size() int

func (*GetServerOptionsResponse) XXX_Unmarshal added in v0.0.49 

func (m *GetServerOptionsResponse) 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)
	GetAllRelays(ctx context.Context, in *GetAllRelaysRequest, opts ...grpc.CallOption) (*GetAllRelaysResponse, error)
	GetRelay(ctx context.Context, in *GetRelayRequest, opts ...grpc.CallOption) (*GetRelayResponse, error)
	CreateRelay(ctx context.Context, in *CreateRelayRequest, opts ...grpc.CallOption) (*CreateRelayResponse, error)
	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)
	DeleteRelay(ctx context.Context, in *DeleteRelayRequest, opts ...grpc.CallOption) (*DeleteRelayResponse, error)
	GetDynamic(ctx context.Context, in *GetDynamicRequest, opts ...grpc.CallOption) (*GetDynamicResponse, error)
	GetAllDynamic(ctx context.Context, in *GetAllDynamicRequest, opts ...grpc.CallOption) (*GetAllDynamicResponse, error)
	CreateDynamic(ctx context.Context, in *CreateDynamicRequest, opts ...grpc.CallOption) (*CreateDynamicResponse, error)
	StopDynamic(ctx context.Context, in *StopDynamicRequest, opts ...grpc.CallOption) (*StopDynamicResponse, error)
	ResumeDynamic(ctx context.Context, in *ResumeDynamicRequest, opts ...grpc.CallOption) (*ResumeDynamicResponse, error)
	UpdateDynamic(ctx context.Context, in *UpdateDynamicRequest, opts ...grpc.CallOption) (*UpdateDynamicResponse, error)
	DeleteDynamic(ctx context.Context, in *DeleteDynamicRequest, opts ...grpc.CallOption) (*DeleteDynamicResponse, error)
	GetServerOptions(ctx context.Context, in *GetServerOptionsRequest, opts ...grpc.CallOption) (*GetServerOptionsResponse, 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)
	GetAllRelays(context.Context, *GetAllRelaysRequest) (*GetAllRelaysResponse, error)
	GetRelay(context.Context, *GetRelayRequest) (*GetRelayResponse, error)
	CreateRelay(context.Context, *CreateRelayRequest) (*CreateRelayResponse, error)
	UpdateRelay(context.Context, *UpdateRelayRequest) (*UpdateRelayResponse, error)
	ResumeRelay(context.Context, *ResumeRelayRequest) (*ResumeRelayResponse, error)
	StopRelay(context.Context, *StopRelayRequest) (*StopRelayResponse, error)
	DeleteRelay(context.Context, *DeleteRelayRequest) (*DeleteRelayResponse, error)
	GetDynamic(context.Context, *GetDynamicRequest) (*GetDynamicResponse, error)
	GetAllDynamic(context.Context, *GetAllDynamicRequest) (*GetAllDynamicResponse, error)
	CreateDynamic(context.Context, *CreateDynamicRequest) (*CreateDynamicResponse, error)
	StopDynamic(context.Context, *StopDynamicRequest) (*StopDynamicResponse, error)
	ResumeDynamic(context.Context, *ResumeDynamicRequest) (*ResumeDynamicResponse, error)
	UpdateDynamic(context.Context, *UpdateDynamicRequest) (*UpdateDynamicResponse, error)
	DeleteDynamic(context.Context, *DeleteDynamicRequest) (*DeleteDynamicResponse, error)
	GetServerOptions(context.Context, *GetServerOptionsRequest) (*GetServerOptionsResponse, error)
}

PlumberServerServer is the server API for PlumberServer service.

type ResumeDynamicRequest added in v0.0.130 

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

Resume a paused relay

func (*ResumeDynamicRequest) Descriptor added in v0.0.130 

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

func (*ResumeDynamicRequest) GetAuth added in v0.0.130 

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

func (*ResumeDynamicRequest) GetDynamicId added in v0.0.130 

func (m *ResumeDynamicRequest) GetDynamicId() string

func (*ResumeDynamicRequest) ProtoMessage added in v0.0.130 

func (*ResumeDynamicRequest) ProtoMessage()

func (*ResumeDynamicRequest) Reset added in v0.0.130 

func (m *ResumeDynamicRequest) Reset()

func (*ResumeDynamicRequest) String added in v0.0.130 

func (m *ResumeDynamicRequest) String() string

func (*ResumeDynamicRequest) XXX_DiscardUnknown added in v0.0.130 

func (m *ResumeDynamicRequest) XXX_DiscardUnknown()

func (*ResumeDynamicRequest) XXX_Marshal added in v0.0.130 

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

func (*ResumeDynamicRequest) XXX_Merge added in v0.0.130 

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

func (*ResumeDynamicRequest) XXX_Size added in v0.0.130 

func (m *ResumeDynamicRequest) XXX_Size() int

func (*ResumeDynamicRequest) XXX_Unmarshal added in v0.0.130 

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

type ResumeDynamicResponse added in v0.0.130 

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

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

func (*ResumeDynamicResponse) GetStatus added in v0.0.130 

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

func (*ResumeDynamicResponse) ProtoMessage added in v0.0.130 

func (*ResumeDynamicResponse) ProtoMessage()

func (*ResumeDynamicResponse) Reset added in v0.0.130 

func (m *ResumeDynamicResponse) Reset()

func (*ResumeDynamicResponse) String added in v0.0.130 

func (m *ResumeDynamicResponse) String() string

func (*ResumeDynamicResponse) XXX_DiscardUnknown added in v0.0.130 

func (m *ResumeDynamicResponse) XXX_DiscardUnknown()

func (*ResumeDynamicResponse) XXX_Marshal added in v0.0.130 

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

func (*ResumeDynamicResponse) XXX_Merge added in v0.0.130 

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

func (*ResumeDynamicResponse) XXX_Size added in v0.0.130 

func (m *ResumeDynamicResponse) XXX_Size() int

func (*ResumeDynamicResponse) XXX_Unmarshal added in v0.0.130 

func (m *ResumeDynamicResponse) 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 StopDynamicRequest added in v0.0.130 

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

Temporarily stop/pause a relay

func (*StopDynamicRequest) Descriptor added in v0.0.130 

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

func (*StopDynamicRequest) GetAuth added in v0.0.130 

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

func (*StopDynamicRequest) GetDynamicId added in v0.0.130 

func (m *StopDynamicRequest) GetDynamicId() string

func (*StopDynamicRequest) ProtoMessage added in v0.0.130 

func (*StopDynamicRequest) ProtoMessage()

func (*StopDynamicRequest) Reset added in v0.0.130 

func (m *StopDynamicRequest) Reset()

func (*StopDynamicRequest) String added in v0.0.130 

func (m *StopDynamicRequest) String() string

func (*StopDynamicRequest) XXX_DiscardUnknown added in v0.0.130 

func (m *StopDynamicRequest) XXX_DiscardUnknown()

func (*StopDynamicRequest) XXX_Marshal added in v0.0.130 

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

func (*StopDynamicRequest) XXX_Merge added in v0.0.130 

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

func (*StopDynamicRequest) XXX_Size added in v0.0.130 

func (m *StopDynamicRequest) XXX_Size() int

func (*StopDynamicRequest) XXX_Unmarshal added in v0.0.130 

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

type StopDynamicResponse added in v0.0.130 

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

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

func (*StopDynamicResponse) GetStatus added in v0.0.130 

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

func (*StopDynamicResponse) ProtoMessage added in v0.0.130 

func (*StopDynamicResponse) ProtoMessage()

func (*StopDynamicResponse) Reset added in v0.0.130 

func (m *StopDynamicResponse) Reset()

func (*StopDynamicResponse) String added in v0.0.130 

func (m *StopDynamicResponse) String() string

func (*StopDynamicResponse) XXX_DiscardUnknown added in v0.0.130 

func (m *StopDynamicResponse) XXX_DiscardUnknown()

func (*StopDynamicResponse) XXX_Marshal added in v0.0.130 

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

func (*StopDynamicResponse) XXX_Merge added in v0.0.130 

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

func (*StopDynamicResponse) XXX_Size added in v0.0.130 

func (m *StopDynamicResponse) XXX_Size() int

func (*StopDynamicResponse) XXX_Unmarshal added in v0.0.130 

func (m *StopDynamicResponse) 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"`
	Options              *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,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) GetOptions added in v0.0.49 

func (m *TestConnectionRequest) GetOptions() *opts.ConnectionOptions

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) CreateDynamic added in v0.0.130 

func (*UnimplementedPlumberServerServer) CreateDynamic(ctx context.Context, req *CreateDynamicRequest) (*CreateDynamicResponse, error)

func (*UnimplementedPlumberServerServer) CreateRelay 

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

func (*UnimplementedPlumberServerServer) DeleteConnection 

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

func (*UnimplementedPlumberServerServer) DeleteDynamic added in v0.0.130 

func (*UnimplementedPlumberServerServer) DeleteDynamic(ctx context.Context, req *DeleteDynamicRequest) (*DeleteDynamicResponse, error)

func (*UnimplementedPlumberServerServer) DeleteRelay 

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

func (*UnimplementedPlumberServerServer) GetAllConnections 

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

func (*UnimplementedPlumberServerServer) GetAllDynamic added in v0.0.130 

func (*UnimplementedPlumberServerServer) GetAllDynamic(ctx context.Context, req *GetAllDynamicRequest) (*GetAllDynamicResponse, error)

func (*UnimplementedPlumberServerServer) GetAllRelays added in v0.0.17 

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

func (*UnimplementedPlumberServerServer) GetConnection added in v0.0.3 

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

func (*UnimplementedPlumberServerServer) GetDynamic added in v0.0.130 

func (*UnimplementedPlumberServerServer) GetDynamic(ctx context.Context, req *GetDynamicRequest) (*GetDynamicResponse, error)

func (*UnimplementedPlumberServerServer) GetRelay added in v0.0.130 

func (*UnimplementedPlumberServerServer) GetRelay(ctx context.Context, req *GetRelayRequest) (*GetRelayResponse, error)

func (*UnimplementedPlumberServerServer) GetServerOptions added in v0.0.49 

func (*UnimplementedPlumberServerServer) GetServerOptions(ctx context.Context, req *GetServerOptionsRequest) (*GetServerOptionsResponse, error)

func (*UnimplementedPlumberServerServer) ResumeDynamic added in v0.0.130 

func (*UnimplementedPlumberServerServer) ResumeDynamic(ctx context.Context, req *ResumeDynamicRequest) (*ResumeDynamicResponse, error)

func (*UnimplementedPlumberServerServer) ResumeRelay added in v0.0.16 

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

func (*UnimplementedPlumberServerServer) StopDynamic added in v0.0.130 

func (*UnimplementedPlumberServerServer) StopDynamic(ctx context.Context, req *StopDynamicRequest) (*StopDynamicResponse, 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) UpdateDynamic added in v0.0.130 

func (*UnimplementedPlumberServerServer) UpdateDynamic(ctx context.Context, req *UpdateDynamicRequest) (*UpdateDynamicResponse, error)

func (*UnimplementedPlumberServerServer) UpdateRelay 

func (*UnimplementedPlumberServerServer) UpdateRelay(ctx context.Context, req *UpdateRelayRequest) (*UpdateRelayResponse, 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"`
	Options              *opts.ConnectionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,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) GetConnectionId 

func (m *UpdateConnectionRequest) GetConnectionId() string

func (*UpdateConnectionRequest) GetOptions added in v0.0.49 

func (m *UpdateConnectionRequest) GetOptions() *opts.ConnectionOptions

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 UpdateDynamicRequest added in v0.0.130 

type UpdateDynamicRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth         `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	DynamicId            string               `protobuf:"bytes,1,opt,name=dynamic_id,json=dynamicId,proto3" json:"dynamic_id,omitempty"`
	Opts                 *opts.DynamicOptions `protobuf:"bytes,2,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

WARNING: Updating a destination that is in-use can result in missing data during replay

func (*UpdateDynamicRequest) Descriptor added in v0.0.130 

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

func (*UpdateDynamicRequest) GetAuth added in v0.0.130 

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

func (*UpdateDynamicRequest) GetDynamicId added in v0.0.130 

func (m *UpdateDynamicRequest) GetDynamicId() string

func (*UpdateDynamicRequest) GetOpts added in v0.0.130 

func (m *UpdateDynamicRequest) GetOpts() *opts.DynamicOptions

func (*UpdateDynamicRequest) ProtoMessage added in v0.0.130 

func (*UpdateDynamicRequest) ProtoMessage()

func (*UpdateDynamicRequest) Reset added in v0.0.130 

func (m *UpdateDynamicRequest) Reset()

func (*UpdateDynamicRequest) String added in v0.0.130 

func (m *UpdateDynamicRequest) String() string

func (*UpdateDynamicRequest) XXX_DiscardUnknown added in v0.0.130 

func (m *UpdateDynamicRequest) XXX_DiscardUnknown()

func (*UpdateDynamicRequest) XXX_Marshal added in v0.0.130 

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

func (*UpdateDynamicRequest) XXX_Merge added in v0.0.130 

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

func (*UpdateDynamicRequest) XXX_Size added in v0.0.130 

func (m *UpdateDynamicRequest) XXX_Size() int

func (*UpdateDynamicRequest) XXX_Unmarshal added in v0.0.130 

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

type UpdateDynamicResponse added in v0.0.130 

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

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

func (*UpdateDynamicResponse) GetStatus added in v0.0.130 

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

func (*UpdateDynamicResponse) ProtoMessage added in v0.0.130 

func (*UpdateDynamicResponse) ProtoMessage()

func (*UpdateDynamicResponse) Reset added in v0.0.130 

func (m *UpdateDynamicResponse) Reset()

func (*UpdateDynamicResponse) String added in v0.0.130 

func (m *UpdateDynamicResponse) String() string

func (*UpdateDynamicResponse) XXX_DiscardUnknown added in v0.0.130 

func (m *UpdateDynamicResponse) XXX_DiscardUnknown()

func (*UpdateDynamicResponse) XXX_Marshal added in v0.0.130 

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

func (*UpdateDynamicResponse) XXX_Merge added in v0.0.130 

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

func (*UpdateDynamicResponse) XXX_Size added in v0.0.130 

func (m *UpdateDynamicResponse) XXX_Size() int

func (*UpdateDynamicResponse) XXX_Unmarshal added in v0.0.130 

func (m *UpdateDynamicResponse) 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"`
	Opts                 *opts.RelayOptions `protobuf:"bytes,2,opt,name=opts,proto3" json:"opts,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) GetOpts added in v0.0.49 

func (m *UpdateRelayRequest) GetOpts() *opts.RelayOptions

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

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.