mbroker

package
v0.0.0-...-bf81f7d Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterBrokerServer 

func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)

Types

type BrokerClient 

type BrokerClient interface {
	ServiceTunnel(ctx context.Context, opts ...grpc.CallOption) (Broker_ServiceTunnelClient, error)
	ConsumerTunnel(ctx context.Context, opts ...grpc.CallOption) (Broker_ConsumerTunnelClient, error)
}

BrokerClient is the client API for Broker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBrokerClient 

func NewBrokerClient(cc *grpc.ClientConn) BrokerClient

type BrokerServer 

type BrokerServer interface {
	ServiceTunnel(Broker_ServiceTunnelServer) error
	ConsumerTunnel(Broker_ConsumerTunnelServer) error
}

BrokerServer is the server API for Broker service.

type Broker_ConsumerTunnelClient 

type Broker_ConsumerTunnelClient interface {
	Send(*ConsumeRequest) error
	Recv() (*ConsumeResponse, error)
	grpc.ClientStream
}

type Broker_ConsumerTunnelServer 

type Broker_ConsumerTunnelServer interface {
	Send(*ConsumeResponse) error
	Recv() (*ConsumeRequest, error)
	grpc.ServerStream
}

type Broker_ServiceTunnelClient 

type Broker_ServiceTunnelClient interface {
	Send(*ServiceRequest) error
	Recv() (*ServiceResponse, error)
	grpc.ClientStream
}

type Broker_ServiceTunnelServer 

type Broker_ServiceTunnelServer interface {
	Send(*ServiceResponse) error
	Recv() (*ServiceRequest, error)
	grpc.ServerStream
}

type CloseChannel 

type CloseChannel struct {
	// channel id
	Channel              int64    `protobuf:"varint,1,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Close specified channel

func (*CloseChannel) Descriptor 

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

func (*CloseChannel) GetChannel 

func (m *CloseChannel) GetChannel() int64

func (*CloseChannel) ProtoMessage 

func (*CloseChannel) ProtoMessage()

func (*CloseChannel) Reset 

func (m *CloseChannel) Reset()

func (*CloseChannel) String 

func (m *CloseChannel) String() string

func (*CloseChannel) XXX_DiscardUnknown 

func (m *CloseChannel) XXX_DiscardUnknown()

func (*CloseChannel) XXX_Marshal 

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

func (*CloseChannel) XXX_Merge 

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

func (*CloseChannel) XXX_Size 

func (m *CloseChannel) XXX_Size() int

func (*CloseChannel) XXX_Unmarshal 

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

type ConsumeRequest 

type ConsumeRequest struct {
	// Types that are valid to be assigned to Msg:
	//	*ConsumeRequest_OpenChannel
	//	*ConsumeRequest_SendData
	Msg                  isConsumeRequest_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

The message from Consumer to the broker - will register or will send data

func (*ConsumeRequest) Descriptor 

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

func (*ConsumeRequest) GetMsg 

func (m *ConsumeRequest) GetMsg() isConsumeRequest_Msg

func (*ConsumeRequest) GetOpenChannel 

func (m *ConsumeRequest) GetOpenChannel() *OpenChannel

func (*ConsumeRequest) GetSendData 

func (m *ConsumeRequest) GetSendData() *Data

func (*ConsumeRequest) ProtoMessage 

func (*ConsumeRequest) ProtoMessage()

func (*ConsumeRequest) Reset 

func (m *ConsumeRequest) Reset()

func (*ConsumeRequest) String 

func (m *ConsumeRequest) String() string

func (*ConsumeRequest) XXX_DiscardUnknown 

func (m *ConsumeRequest) XXX_DiscardUnknown()

func (*ConsumeRequest) XXX_Marshal 

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

func (*ConsumeRequest) XXX_Merge 

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

func (*ConsumeRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConsumeRequest) XXX_Size 

func (m *ConsumeRequest) XXX_Size() int

func (*ConsumeRequest) XXX_Unmarshal 

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

type ConsumeRequest_OpenChannel 

type ConsumeRequest_OpenChannel struct {
	OpenChannel *OpenChannel `protobuf:"bytes,1,opt,name=open_channel,json=openChannel,proto3,oneof"`
}

type ConsumeRequest_SendData 

type ConsumeRequest_SendData struct {
	SendData *Data `protobuf:"bytes,2,opt,name=send_data,json=sendData,proto3,oneof"`
}

type ConsumeResponse 

type ConsumeResponse struct {
	// Types that are valid to be assigned to Msg:
	//	*ConsumeResponse_ChannelOpened
	//	*ConsumeResponse_ChannelClosed
	//	*ConsumeResponse_RecvData
	Msg                  isConsumeResponse_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConsumeResponse) Descriptor 

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

func (*ConsumeResponse) GetChannelClosed 

func (m *ConsumeResponse) GetChannelClosed() *NotifyChannelClosed

func (*ConsumeResponse) GetChannelOpened 

func (m *ConsumeResponse) GetChannelOpened() *NotifyChannelOpened

func (*ConsumeResponse) GetMsg 

func (m *ConsumeResponse) GetMsg() isConsumeResponse_Msg

func (*ConsumeResponse) GetRecvData 

func (m *ConsumeResponse) GetRecvData() *Data

func (*ConsumeResponse) ProtoMessage 

func (*ConsumeResponse) ProtoMessage()

func (*ConsumeResponse) Reset 

func (m *ConsumeResponse) Reset()

func (*ConsumeResponse) String 

func (m *ConsumeResponse) String() string

func (*ConsumeResponse) XXX_DiscardUnknown 

func (m *ConsumeResponse) XXX_DiscardUnknown()

func (*ConsumeResponse) XXX_Marshal 

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

func (*ConsumeResponse) XXX_Merge 

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

func (*ConsumeResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConsumeResponse) XXX_Size 

func (m *ConsumeResponse) XXX_Size() int

func (*ConsumeResponse) XXX_Unmarshal 

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

type ConsumeResponse_ChannelClosed 

type ConsumeResponse_ChannelClosed struct {
	ChannelClosed *NotifyChannelClosed `protobuf:"bytes,2,opt,name=channel_closed,json=channelClosed,proto3,oneof"`
}

type ConsumeResponse_ChannelOpened 

type ConsumeResponse_ChannelOpened struct {
	ChannelOpened *NotifyChannelOpened `protobuf:"bytes,1,opt,name=channel_opened,json=channelOpened,proto3,oneof"`
}

type ConsumeResponse_RecvData 

type ConsumeResponse_RecvData struct {
	RecvData *Data `protobuf:"bytes,3,opt,name=recv_data,json=recvData,proto3,oneof"`
}

type Data 

type Data struct {
	// channel id identifying channel between client server (uniquely assigned within client runtime context)
	Channel int64 `protobuf:"varint,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// raw data
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The message with raw data

func (*Data) Descriptor 

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

func (*Data) GetChannel 

func (m *Data) GetChannel() int64

func (*Data) GetData 

func (m *Data) GetData() []byte

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) Reset 

func (m *Data) Reset()

func (*Data) String 

func (m *Data) String() string

func (*Data) XXX_DiscardUnknown 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal 

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

func (*Data) XXX_Merge 

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

func (*Data) XXX_Size 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal 

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

type NotifyChannelClosed 

type NotifyChannelClosed struct {
	// channel id
	Channel              int64    `protobuf:"varint,1,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NotifyChannelClosed) Descriptor 

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

func (*NotifyChannelClosed) GetChannel 

func (m *NotifyChannelClosed) GetChannel() int64

func (*NotifyChannelClosed) ProtoMessage 

func (*NotifyChannelClosed) ProtoMessage()

func (*NotifyChannelClosed) Reset 

func (m *NotifyChannelClosed) Reset()

func (*NotifyChannelClosed) String 

func (m *NotifyChannelClosed) String() string

func (*NotifyChannelClosed) XXX_DiscardUnknown 

func (m *NotifyChannelClosed) XXX_DiscardUnknown()

func (*NotifyChannelClosed) XXX_Marshal 

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

func (*NotifyChannelClosed) XXX_Merge 

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

func (*NotifyChannelClosed) XXX_Size 

func (m *NotifyChannelClosed) XXX_Size() int

func (*NotifyChannelClosed) XXX_Unmarshal 

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

type NotifyChannelOpened 

type NotifyChannelOpened struct {
	// channel id set by client (or client broker when routing)
	Channel              int64    `protobuf:"varint,1,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Notification messages

func (*NotifyChannelOpened) Descriptor 

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

func (*NotifyChannelOpened) GetChannel 

func (m *NotifyChannelOpened) GetChannel() int64

func (*NotifyChannelOpened) ProtoMessage 

func (*NotifyChannelOpened) ProtoMessage()

func (*NotifyChannelOpened) Reset 

func (m *NotifyChannelOpened) Reset()

func (*NotifyChannelOpened) String 

func (m *NotifyChannelOpened) String() string

func (*NotifyChannelOpened) XXX_DiscardUnknown 

func (m *NotifyChannelOpened) XXX_DiscardUnknown()

func (*NotifyChannelOpened) XXX_Marshal 

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

func (*NotifyChannelOpened) XXX_Merge 

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

func (*NotifyChannelOpened) XXX_Size 

func (m *NotifyChannelOpened) XXX_Size() int

func (*NotifyChannelOpened) XXX_Unmarshal 

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

type OpenChannel 

type OpenChannel struct {
	// Service to consume
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// channel id set by client (or client broker when routing)
	Channel              int64    `protobuf:"varint,2,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Open designated channel to the service

func (*OpenChannel) Descriptor 

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

func (*OpenChannel) GetChannel 

func (m *OpenChannel) GetChannel() int64

func (*OpenChannel) GetService 

func (m *OpenChannel) GetService() string

func (*OpenChannel) ProtoMessage 

func (*OpenChannel) ProtoMessage()

func (*OpenChannel) Reset 

func (m *OpenChannel) Reset()

func (*OpenChannel) String 

func (m *OpenChannel) String() string

func (*OpenChannel) XXX_DiscardUnknown 

func (m *OpenChannel) XXX_DiscardUnknown()

func (*OpenChannel) XXX_Marshal 

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

func (*OpenChannel) XXX_Merge 

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

func (*OpenChannel) XXX_Size 

func (m *OpenChannel) XXX_Size() int

func (*OpenChannel) XXX_Unmarshal 

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

type ServiceRequest 

type ServiceRequest struct {
	// Types that are valid to be assigned to Msg:
	//	*ServiceRequest_RegisterProvider_
	//	*ServiceRequest_SendData
	Msg                  isServiceRequest_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

The message from Service to the broker - will register or will send data

func (*ServiceRequest) Descriptor 

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

func (*ServiceRequest) GetMsg 

func (m *ServiceRequest) GetMsg() isServiceRequest_Msg

func (*ServiceRequest) GetRegisterProvider 

func (m *ServiceRequest) GetRegisterProvider() *ServiceRequest_RegisterProvider

func (*ServiceRequest) GetSendData 

func (m *ServiceRequest) GetSendData() *Data

func (*ServiceRequest) ProtoMessage 

func (*ServiceRequest) ProtoMessage()

func (*ServiceRequest) Reset 

func (m *ServiceRequest) Reset()

func (*ServiceRequest) String 

func (m *ServiceRequest) String() string

func (*ServiceRequest) XXX_DiscardUnknown 

func (m *ServiceRequest) XXX_DiscardUnknown()

func (*ServiceRequest) XXX_Marshal 

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

func (*ServiceRequest) XXX_Merge 

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

func (*ServiceRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceRequest) XXX_Size 

func (m *ServiceRequest) XXX_Size() int

func (*ServiceRequest) XXX_Unmarshal 

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

type ServiceRequest_RegisterProvider 

type ServiceRequest_RegisterProvider struct {
	// device name, e.g. projects/xyz/devices/abcd (may integrate this way with goten: auth, etc)
	Device string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	// service name, e.g. ssh
	Service              string   `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceRequest_RegisterProvider) Descriptor 

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

func (*ServiceRequest_RegisterProvider) GetDevice 

func (m *ServiceRequest_RegisterProvider) GetDevice() string

func (*ServiceRequest_RegisterProvider) GetService 

func (m *ServiceRequest_RegisterProvider) GetService() string

func (*ServiceRequest_RegisterProvider) ProtoMessage 

func (*ServiceRequest_RegisterProvider) ProtoMessage()

func (*ServiceRequest_RegisterProvider) Reset 

func (m *ServiceRequest_RegisterProvider) Reset()

func (*ServiceRequest_RegisterProvider) String 

func (m *ServiceRequest_RegisterProvider) String() string

func (*ServiceRequest_RegisterProvider) XXX_DiscardUnknown 

func (m *ServiceRequest_RegisterProvider) XXX_DiscardUnknown()

func (*ServiceRequest_RegisterProvider) XXX_Marshal 

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

func (*ServiceRequest_RegisterProvider) XXX_Merge 

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

func (*ServiceRequest_RegisterProvider) XXX_Size 

func (m *ServiceRequest_RegisterProvider) XXX_Size() int

func (*ServiceRequest_RegisterProvider) XXX_Unmarshal 

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

type ServiceRequest_RegisterProvider_ 

type ServiceRequest_RegisterProvider_ struct {
	RegisterProvider *ServiceRequest_RegisterProvider `protobuf:"bytes,1,opt,name=register_provider,json=registerProvider,proto3,oneof"`
}

type ServiceRequest_SendData 

type ServiceRequest_SendData struct {
	SendData *Data `protobuf:"bytes,3,opt,name=send_data,json=sendData,proto3,oneof"`
}

type ServiceResponse 

type ServiceResponse struct {
	// Types that are valid to be assigned to Msg:
	//	*ServiceResponse_ChannelOpened
	//	*ServiceResponse_ChannelClosed
	//	*ServiceResponse_RecvData
	Msg                  isServiceResponse_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ServiceResponse) Descriptor 

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

func (*ServiceResponse) GetChannelClosed 

func (m *ServiceResponse) GetChannelClosed() *NotifyChannelClosed

func (*ServiceResponse) GetChannelOpened 

func (m *ServiceResponse) GetChannelOpened() *NotifyChannelOpened

func (*ServiceResponse) GetMsg 

func (m *ServiceResponse) GetMsg() isServiceResponse_Msg

func (*ServiceResponse) GetRecvData 

func (m *ServiceResponse) GetRecvData() *Data

func (*ServiceResponse) ProtoMessage 

func (*ServiceResponse) ProtoMessage()

func (*ServiceResponse) Reset 

func (m *ServiceResponse) Reset()

func (*ServiceResponse) String 

func (m *ServiceResponse) String() string

func (*ServiceResponse) XXX_DiscardUnknown 

func (m *ServiceResponse) XXX_DiscardUnknown()

func (*ServiceResponse) XXX_Marshal 

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

func (*ServiceResponse) XXX_Merge 

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

func (*ServiceResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceResponse) XXX_Size 

func (m *ServiceResponse) XXX_Size() int

func (*ServiceResponse) XXX_Unmarshal 

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

type ServiceResponse_ChannelClosed 

type ServiceResponse_ChannelClosed struct {
	ChannelClosed *NotifyChannelClosed `protobuf:"bytes,2,opt,name=channel_closed,json=channelClosed,proto3,oneof"`
}

type ServiceResponse_ChannelOpened 

type ServiceResponse_ChannelOpened struct {
	ChannelOpened *NotifyChannelOpened `protobuf:"bytes,1,opt,name=channel_opened,json=channelOpened,proto3,oneof"`
}

type ServiceResponse_RecvData 

type ServiceResponse_RecvData struct {
	RecvData *Data `protobuf:"bytes,3,opt,name=recv_data,json=recvData,proto3,oneof"`
}

type UnimplementedBrokerServer 

type UnimplementedBrokerServer struct {
}

UnimplementedBrokerServer can be embedded to have forward compatible implementations.

func (*UnimplementedBrokerServer) ConsumerTunnel 

func (*UnimplementedBrokerServer) ConsumerTunnel(srv Broker_ConsumerTunnelServer) error

func (*UnimplementedBrokerServer) ServiceTunnel 

func (*UnimplementedBrokerServer) ServiceTunnel(srv Broker_ServiceTunnelServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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