proto

Documentation

Index

• func RegisterEndPointServer(s *grpc.Server, srv EndPointServer)
• func RegisterReceiverServer(s *grpc.Server, srv ReceiverServer)
• type EndPointClient
  • func NewEndPointClient(cc grpc.ClientConnInterface) EndPointClient
• type EndPointServer
• type JoinResult
  • func (*JoinResult) Descriptor() ([]byte, []int)
  • func (m *JoinResult) GetResult() bool
  • func (*JoinResult) ProtoMessage()
  • func (m *JoinResult) Reset()
  • func (m *JoinResult) String() string
  • func (m *JoinResult) XXX_DiscardUnknown()
  • func (m *JoinResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *JoinResult) XXX_Merge(src proto.Message)
  • func (m *JoinResult) XXX_Size() int
  • func (m *JoinResult) XXX_Unmarshal(b []byte) error
• type ProviderInfo
  • func (*ProviderInfo) Descriptor() ([]byte, []int)
  • func (m *ProviderInfo) GetIp() string
  • func (m *ProviderInfo) GetPort() string
  • func (m *ProviderInfo) GetServiceName() string
  • func (*ProviderInfo) ProtoMessage()
  • func (m *ProviderInfo) Reset()
  • func (m *ProviderInfo) String() string
  • func (m *ProviderInfo) XXX_DiscardUnknown()
  • func (m *ProviderInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ProviderInfo) XXX_Merge(src proto.Message)
  • func (m *ProviderInfo) XXX_Size() int
  • func (m *ProviderInfo) XXX_Unmarshal(b []byte) error
• type ReceiverClient
  • func NewReceiverClient(cc grpc.ClientConnInterface) ReceiverClient
• type ReceiverServer
• type ReportResult
  • func (*ReportResult) Descriptor() ([]byte, []int)
  • func (m *ReportResult) GetResult() bool
  • func (*ReportResult) ProtoMessage()
  • func (m *ReportResult) Reset()
  • func (m *ReportResult) String() string
  • func (m *ReportResult) XXX_DiscardUnknown()
  • func (m *ReportResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ReportResult) XXX_Merge(src proto.Message)
  • func (m *ReportResult) XXX_Size() int
  • func (m *ReportResult) XXX_Unmarshal(b []byte) error
• type UnimplementedEndPointServer
  • func (*UnimplementedEndPointServer) GetServiceInfo(ctx context.Context, req *ProviderInfo) (*ProviderInfo, error)
• type UnimplementedReceiverServer
  • func (*UnimplementedReceiverServer) JoinServiceHub(ctx context.Context, req *ProviderInfo) (*JoinResult, error)
  • func (*UnimplementedReceiverServer) ReportActive(ctx context.Context, req *ProviderInfo) (*ReportResult, error)

Functions

func RegisterEndPointServer

func RegisterEndPointServer(s *grpc.Server, srv EndPointServer)

func RegisterReceiverServer

func RegisterReceiverServer(s *grpc.Server, srv ReceiverServer)

Types

type EndPointClient

type EndPointClient interface {
	GetServiceInfo(ctx context.Context, in *ProviderInfo, opts ...grpc.CallOption) (*ProviderInfo, error)
}

EndPointClient is the client API for EndPoint service.

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

func NewEndPointClient

func NewEndPointClient(cc grpc.ClientConnInterface) EndPointClient

type EndPointServer

type EndPointServer interface {
	GetServiceInfo(context.Context, *ProviderInfo) (*ProviderInfo, error)
}

EndPointServer is the server API for EndPoint service.

type JoinResult

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

func (*JoinResult) Descriptor

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

func (*JoinResult) GetResult

func (m *JoinResult) GetResult() bool

func (*JoinResult) ProtoMessage

func (*JoinResult) ProtoMessage()

func (*JoinResult) Reset

func (m *JoinResult) Reset()

func (*JoinResult) String

func (m *JoinResult) String() string

func (*JoinResult) XXX_DiscardUnknown

func (m *JoinResult) XXX_DiscardUnknown()

func (*JoinResult) XXX_Marshal

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

func (*JoinResult) XXX_Merge

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

func (*JoinResult) XXX_Size

func (m *JoinResult) XXX_Size() int

func (*JoinResult) XXX_Unmarshal

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

type ProviderInfo

type ProviderInfo struct {
	ServiceName          string   `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	Ip                   string   `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Port                 string   `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProviderInfo) Descriptor

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

func (*ProviderInfo) GetIp

func (m *ProviderInfo) GetIp() string

func (*ProviderInfo) GetPort

func (m *ProviderInfo) GetPort() string

func (*ProviderInfo) GetServiceName

func (m *ProviderInfo) GetServiceName() string

func (*ProviderInfo) ProtoMessage

func (*ProviderInfo) ProtoMessage()

func (*ProviderInfo) Reset

func (m *ProviderInfo) Reset()

func (*ProviderInfo) String

func (m *ProviderInfo) String() string

func (*ProviderInfo) XXX_DiscardUnknown

func (m *ProviderInfo) XXX_DiscardUnknown()

func (*ProviderInfo) XXX_Marshal

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

func (*ProviderInfo) XXX_Merge

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

func (*ProviderInfo) XXX_Size

func (m *ProviderInfo) XXX_Size() int

func (*ProviderInfo) XXX_Unmarshal

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

type ReceiverClient

type ReceiverClient interface {
	JoinServiceHub(ctx context.Context, in *ProviderInfo, opts ...grpc.CallOption) (*JoinResult, error)
	ReportActive(ctx context.Context, in *ProviderInfo, opts ...grpc.CallOption) (*ReportResult, error)
}

ReceiverClient is the client API for Receiver service.

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

func NewReceiverClient

func NewReceiverClient(cc grpc.ClientConnInterface) ReceiverClient

type ReceiverServer

type ReceiverServer interface {
	JoinServiceHub(context.Context, *ProviderInfo) (*JoinResult, error)
	ReportActive(context.Context, *ProviderInfo) (*ReportResult, error)
}

ReceiverServer is the server API for Receiver service.

type ReportResult

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

func (*ReportResult) Descriptor

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

func (*ReportResult) GetResult

func (m *ReportResult) GetResult() bool

func (*ReportResult) ProtoMessage

func (*ReportResult) ProtoMessage()

func (*ReportResult) Reset

func (m *ReportResult) Reset()

func (*ReportResult) String

func (m *ReportResult) String() string

func (*ReportResult) XXX_DiscardUnknown

func (m *ReportResult) XXX_DiscardUnknown()

func (*ReportResult) XXX_Marshal

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

func (*ReportResult) XXX_Merge

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

func (*ReportResult) XXX_Size

func (m *ReportResult) XXX_Size() int

func (*ReportResult) XXX_Unmarshal

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

type UnimplementedEndPointServer

type UnimplementedEndPointServer struct {
}

UnimplementedEndPointServer can be embedded to have forward compatible implementations.

func (*UnimplementedEndPointServer) GetServiceInfo

func (*UnimplementedEndPointServer) GetServiceInfo(ctx context.Context, req *ProviderInfo) (*ProviderInfo, error)

type UnimplementedReceiverServer

type UnimplementedReceiverServer struct {
}

UnimplementedReceiverServer can be embedded to have forward compatible implementations.

func (*UnimplementedReceiverServer) JoinServiceHub

func (*UnimplementedReceiverServer) JoinServiceHub(ctx context.Context, req *ProviderInfo) (*JoinResult, error)

func (*UnimplementedReceiverServer) ReportActive

func (*UnimplementedReceiverServer) ReportActive(ctx context.Context, req *ProviderInfo) (*ReportResult, error)