Documentation ¶
Index ¶
- Variables
- func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)
- type BrokerClient
- type BrokerServer
- type LookupPrimitiveRequest
- func (*LookupPrimitiveRequest) Descriptor() ([]byte, []int)
- func (m *LookupPrimitiveRequest) GetPrimitiveID() PrimitiveId
- func (m *LookupPrimitiveRequest) Marshal() (dAtA []byte, err error)
- func (m *LookupPrimitiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LookupPrimitiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LookupPrimitiveRequest) ProtoMessage()
- func (m *LookupPrimitiveRequest) Reset()
- func (m *LookupPrimitiveRequest) Size() (n int)
- func (m *LookupPrimitiveRequest) String() string
- func (m *LookupPrimitiveRequest) Unmarshal(dAtA []byte) error
- func (m *LookupPrimitiveRequest) XXX_DiscardUnknown()
- func (m *LookupPrimitiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LookupPrimitiveRequest) XXX_Merge(src proto.Message)
- func (m *LookupPrimitiveRequest) XXX_Size() int
- func (m *LookupPrimitiveRequest) XXX_Unmarshal(b []byte) error
- type LookupPrimitiveResponse
- func (*LookupPrimitiveResponse) Descriptor() ([]byte, []int)
- func (m *LookupPrimitiveResponse) GetAddress() PrimitiveAddress
- func (m *LookupPrimitiveResponse) Marshal() (dAtA []byte, err error)
- func (m *LookupPrimitiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *LookupPrimitiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LookupPrimitiveResponse) ProtoMessage()
- func (m *LookupPrimitiveResponse) Reset()
- func (m *LookupPrimitiveResponse) Size() (n int)
- func (m *LookupPrimitiveResponse) String() string
- func (m *LookupPrimitiveResponse) Unmarshal(dAtA []byte) error
- func (m *LookupPrimitiveResponse) XXX_DiscardUnknown()
- func (m *LookupPrimitiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LookupPrimitiveResponse) XXX_Merge(src proto.Message)
- func (m *LookupPrimitiveResponse) XXX_Size() int
- func (m *LookupPrimitiveResponse) XXX_Unmarshal(b []byte) error
- type PrimitiveAddress
- func (*PrimitiveAddress) Descriptor() ([]byte, []int)
- func (m *PrimitiveAddress) GetHost() string
- func (m *PrimitiveAddress) GetPort() int32
- func (m *PrimitiveAddress) Marshal() (dAtA []byte, err error)
- func (m *PrimitiveAddress) MarshalTo(dAtA []byte) (int, error)
- func (m *PrimitiveAddress) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrimitiveAddress) ProtoMessage()
- func (m *PrimitiveAddress) Reset()
- func (m *PrimitiveAddress) Size() (n int)
- func (m *PrimitiveAddress) String() string
- func (m *PrimitiveAddress) Unmarshal(dAtA []byte) error
- func (m *PrimitiveAddress) XXX_DiscardUnknown()
- func (m *PrimitiveAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveAddress) XXX_Merge(src proto.Message)
- func (m *PrimitiveAddress) XXX_Size() int
- func (m *PrimitiveAddress) XXX_Unmarshal(b []byte) error
- type PrimitiveId
- func (*PrimitiveId) Descriptor() ([]byte, []int)
- func (m *PrimitiveId) GetName() string
- func (m *PrimitiveId) GetNamespace() string
- func (m *PrimitiveId) GetType() string
- func (m *PrimitiveId) Marshal() (dAtA []byte, err error)
- func (m *PrimitiveId) MarshalTo(dAtA []byte) (int, error)
- func (m *PrimitiveId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrimitiveId) ProtoMessage()
- func (m *PrimitiveId) Reset()
- func (m *PrimitiveId) Size() (n int)
- func (m *PrimitiveId) String() string
- func (m *PrimitiveId) Unmarshal(dAtA []byte) error
- func (m *PrimitiveId) XXX_DiscardUnknown()
- func (m *PrimitiveId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveId) XXX_Merge(src proto.Message)
- func (m *PrimitiveId) XXX_Size() int
- func (m *PrimitiveId) XXX_Unmarshal(b []byte) error
- type RegisterPrimitiveRequest
- func (*RegisterPrimitiveRequest) Descriptor() ([]byte, []int)
- func (m *RegisterPrimitiveRequest) GetAddress() PrimitiveAddress
- func (m *RegisterPrimitiveRequest) GetPrimitiveID() PrimitiveId
- func (m *RegisterPrimitiveRequest) Marshal() (dAtA []byte, err error)
- func (m *RegisterPrimitiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterPrimitiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterPrimitiveRequest) ProtoMessage()
- func (m *RegisterPrimitiveRequest) Reset()
- func (m *RegisterPrimitiveRequest) Size() (n int)
- func (m *RegisterPrimitiveRequest) String() string
- func (m *RegisterPrimitiveRequest) Unmarshal(dAtA []byte) error
- func (m *RegisterPrimitiveRequest) XXX_DiscardUnknown()
- func (m *RegisterPrimitiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterPrimitiveRequest) XXX_Merge(src proto.Message)
- func (m *RegisterPrimitiveRequest) XXX_Size() int
- func (m *RegisterPrimitiveRequest) XXX_Unmarshal(b []byte) error
- type RegisterPrimitiveResponse
- func (*RegisterPrimitiveResponse) Descriptor() ([]byte, []int)
- func (m *RegisterPrimitiveResponse) Marshal() (dAtA []byte, err error)
- func (m *RegisterPrimitiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterPrimitiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterPrimitiveResponse) ProtoMessage()
- func (m *RegisterPrimitiveResponse) Reset()
- func (m *RegisterPrimitiveResponse) Size() (n int)
- func (m *RegisterPrimitiveResponse) String() string
- func (m *RegisterPrimitiveResponse) Unmarshal(dAtA []byte) error
- func (m *RegisterPrimitiveResponse) XXX_DiscardUnknown()
- func (m *RegisterPrimitiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterPrimitiveResponse) XXX_Merge(src proto.Message)
- func (m *RegisterPrimitiveResponse) XXX_Size() int
- func (m *RegisterPrimitiveResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedBrokerServer
- func (*UnimplementedBrokerServer) LookupPrimitive(ctx context.Context, req *LookupPrimitiveRequest) (*LookupPrimitiveResponse, error)
- func (*UnimplementedBrokerServer) RegisterPrimitive(ctx context.Context, req *RegisterPrimitiveRequest) (*RegisterPrimitiveResponse, error)
- func (*UnimplementedBrokerServer) UnregisterPrimitive(ctx context.Context, req *UnregisterPrimitiveRequest) (*UnregisterPrimitiveResponse, error)
- type UnregisterPrimitiveRequest
- func (*UnregisterPrimitiveRequest) Descriptor() ([]byte, []int)
- func (m *UnregisterPrimitiveRequest) GetPrimitiveID() PrimitiveId
- func (m *UnregisterPrimitiveRequest) Marshal() (dAtA []byte, err error)
- func (m *UnregisterPrimitiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UnregisterPrimitiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnregisterPrimitiveRequest) ProtoMessage()
- func (m *UnregisterPrimitiveRequest) Reset()
- func (m *UnregisterPrimitiveRequest) Size() (n int)
- func (m *UnregisterPrimitiveRequest) String() string
- func (m *UnregisterPrimitiveRequest) Unmarshal(dAtA []byte) error
- func (m *UnregisterPrimitiveRequest) XXX_DiscardUnknown()
- func (m *UnregisterPrimitiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnregisterPrimitiveRequest) XXX_Merge(src proto.Message)
- func (m *UnregisterPrimitiveRequest) XXX_Size() int
- func (m *UnregisterPrimitiveRequest) XXX_Unmarshal(b []byte) error
- type UnregisterPrimitiveResponse
- func (*UnregisterPrimitiveResponse) Descriptor() ([]byte, []int)
- func (m *UnregisterPrimitiveResponse) Marshal() (dAtA []byte, err error)
- func (m *UnregisterPrimitiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UnregisterPrimitiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnregisterPrimitiveResponse) ProtoMessage()
- func (m *UnregisterPrimitiveResponse) Reset()
- func (m *UnregisterPrimitiveResponse) Size() (n int)
- func (m *UnregisterPrimitiveResponse) String() string
- func (m *UnregisterPrimitiveResponse) Unmarshal(dAtA []byte) error
- func (m *UnregisterPrimitiveResponse) XXX_DiscardUnknown()
- func (m *UnregisterPrimitiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnregisterPrimitiveResponse) XXX_Merge(src proto.Message)
- func (m *UnregisterPrimitiveResponse) XXX_Size() int
- func (m *UnregisterPrimitiveResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterBrokerServer ¶
func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)
Types ¶
type BrokerClient ¶
type BrokerClient interface { RegisterPrimitive(ctx context.Context, in *RegisterPrimitiveRequest, opts ...grpc.CallOption) (*RegisterPrimitiveResponse, error) UnregisterPrimitive(ctx context.Context, in *UnregisterPrimitiveRequest, opts ...grpc.CallOption) (*UnregisterPrimitiveResponse, error) LookupPrimitive(ctx context.Context, in *LookupPrimitiveRequest, opts ...grpc.CallOption) (*LookupPrimitiveResponse, 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 { RegisterPrimitive(context.Context, *RegisterPrimitiveRequest) (*RegisterPrimitiveResponse, error) UnregisterPrimitive(context.Context, *UnregisterPrimitiveRequest) (*UnregisterPrimitiveResponse, error) LookupPrimitive(context.Context, *LookupPrimitiveRequest) (*LookupPrimitiveResponse, error) }
BrokerServer is the server API for Broker service.
type LookupPrimitiveRequest ¶
type LookupPrimitiveRequest struct {
PrimitiveID PrimitiveId `protobuf:"bytes,1,opt,name=primitive_id,json=primitiveId,proto3" json:"primitive_id"`
}
func (*LookupPrimitiveRequest) Descriptor ¶
func (*LookupPrimitiveRequest) Descriptor() ([]byte, []int)
func (*LookupPrimitiveRequest) GetPrimitiveID ¶
func (m *LookupPrimitiveRequest) GetPrimitiveID() PrimitiveId
func (*LookupPrimitiveRequest) Marshal ¶
func (m *LookupPrimitiveRequest) Marshal() (dAtA []byte, err error)
func (*LookupPrimitiveRequest) MarshalTo ¶
func (m *LookupPrimitiveRequest) MarshalTo(dAtA []byte) (int, error)
func (*LookupPrimitiveRequest) MarshalToSizedBuffer ¶
func (m *LookupPrimitiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LookupPrimitiveRequest) ProtoMessage ¶
func (*LookupPrimitiveRequest) ProtoMessage()
func (*LookupPrimitiveRequest) Reset ¶
func (m *LookupPrimitiveRequest) Reset()
func (*LookupPrimitiveRequest) Size ¶
func (m *LookupPrimitiveRequest) Size() (n int)
func (*LookupPrimitiveRequest) String ¶
func (m *LookupPrimitiveRequest) String() string
func (*LookupPrimitiveRequest) Unmarshal ¶
func (m *LookupPrimitiveRequest) Unmarshal(dAtA []byte) error
func (*LookupPrimitiveRequest) XXX_DiscardUnknown ¶
func (m *LookupPrimitiveRequest) XXX_DiscardUnknown()
func (*LookupPrimitiveRequest) XXX_Marshal ¶
func (m *LookupPrimitiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LookupPrimitiveRequest) XXX_Merge ¶
func (m *LookupPrimitiveRequest) XXX_Merge(src proto.Message)
func (*LookupPrimitiveRequest) XXX_Size ¶
func (m *LookupPrimitiveRequest) XXX_Size() int
func (*LookupPrimitiveRequest) XXX_Unmarshal ¶
func (m *LookupPrimitiveRequest) XXX_Unmarshal(b []byte) error
type LookupPrimitiveResponse ¶
type LookupPrimitiveResponse struct {
Address PrimitiveAddress `protobuf:"bytes,1,opt,name=address,proto3" json:"address"`
}
func (*LookupPrimitiveResponse) Descriptor ¶
func (*LookupPrimitiveResponse) Descriptor() ([]byte, []int)
func (*LookupPrimitiveResponse) GetAddress ¶
func (m *LookupPrimitiveResponse) GetAddress() PrimitiveAddress
func (*LookupPrimitiveResponse) Marshal ¶
func (m *LookupPrimitiveResponse) Marshal() (dAtA []byte, err error)
func (*LookupPrimitiveResponse) MarshalTo ¶
func (m *LookupPrimitiveResponse) MarshalTo(dAtA []byte) (int, error)
func (*LookupPrimitiveResponse) MarshalToSizedBuffer ¶
func (m *LookupPrimitiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LookupPrimitiveResponse) ProtoMessage ¶
func (*LookupPrimitiveResponse) ProtoMessage()
func (*LookupPrimitiveResponse) Reset ¶
func (m *LookupPrimitiveResponse) Reset()
func (*LookupPrimitiveResponse) Size ¶
func (m *LookupPrimitiveResponse) Size() (n int)
func (*LookupPrimitiveResponse) String ¶
func (m *LookupPrimitiveResponse) String() string
func (*LookupPrimitiveResponse) Unmarshal ¶
func (m *LookupPrimitiveResponse) Unmarshal(dAtA []byte) error
func (*LookupPrimitiveResponse) XXX_DiscardUnknown ¶
func (m *LookupPrimitiveResponse) XXX_DiscardUnknown()
func (*LookupPrimitiveResponse) XXX_Marshal ¶
func (m *LookupPrimitiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LookupPrimitiveResponse) XXX_Merge ¶
func (m *LookupPrimitiveResponse) XXX_Merge(src proto.Message)
func (*LookupPrimitiveResponse) XXX_Size ¶
func (m *LookupPrimitiveResponse) XXX_Size() int
func (*LookupPrimitiveResponse) XXX_Unmarshal ¶
func (m *LookupPrimitiveResponse) XXX_Unmarshal(b []byte) error
type PrimitiveAddress ¶
type PrimitiveAddress struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` }
func (*PrimitiveAddress) Descriptor ¶
func (*PrimitiveAddress) Descriptor() ([]byte, []int)
func (*PrimitiveAddress) GetHost ¶
func (m *PrimitiveAddress) GetHost() string
func (*PrimitiveAddress) GetPort ¶
func (m *PrimitiveAddress) GetPort() int32
func (*PrimitiveAddress) Marshal ¶
func (m *PrimitiveAddress) Marshal() (dAtA []byte, err error)
func (*PrimitiveAddress) MarshalToSizedBuffer ¶
func (m *PrimitiveAddress) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrimitiveAddress) ProtoMessage ¶
func (*PrimitiveAddress) ProtoMessage()
func (*PrimitiveAddress) Reset ¶
func (m *PrimitiveAddress) Reset()
func (*PrimitiveAddress) Size ¶
func (m *PrimitiveAddress) Size() (n int)
func (*PrimitiveAddress) String ¶
func (m *PrimitiveAddress) String() string
func (*PrimitiveAddress) Unmarshal ¶
func (m *PrimitiveAddress) Unmarshal(dAtA []byte) error
func (*PrimitiveAddress) XXX_DiscardUnknown ¶
func (m *PrimitiveAddress) XXX_DiscardUnknown()
func (*PrimitiveAddress) XXX_Marshal ¶
func (m *PrimitiveAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimitiveAddress) XXX_Merge ¶
func (m *PrimitiveAddress) XXX_Merge(src proto.Message)
func (*PrimitiveAddress) XXX_Size ¶
func (m *PrimitiveAddress) XXX_Size() int
func (*PrimitiveAddress) XXX_Unmarshal ¶
func (m *PrimitiveAddress) XXX_Unmarshal(b []byte) error
type PrimitiveId ¶
type PrimitiveId struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` }
func (*PrimitiveId) Descriptor ¶
func (*PrimitiveId) Descriptor() ([]byte, []int)
func (*PrimitiveId) GetName ¶
func (m *PrimitiveId) GetName() string
func (*PrimitiveId) GetNamespace ¶
func (m *PrimitiveId) GetNamespace() string
func (*PrimitiveId) GetType ¶
func (m *PrimitiveId) GetType() string
func (*PrimitiveId) Marshal ¶
func (m *PrimitiveId) Marshal() (dAtA []byte, err error)
func (*PrimitiveId) MarshalToSizedBuffer ¶
func (m *PrimitiveId) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrimitiveId) ProtoMessage ¶
func (*PrimitiveId) ProtoMessage()
func (*PrimitiveId) Reset ¶
func (m *PrimitiveId) Reset()
func (*PrimitiveId) Size ¶
func (m *PrimitiveId) Size() (n int)
func (*PrimitiveId) String ¶
func (m *PrimitiveId) String() string
func (*PrimitiveId) Unmarshal ¶
func (m *PrimitiveId) Unmarshal(dAtA []byte) error
func (*PrimitiveId) XXX_DiscardUnknown ¶
func (m *PrimitiveId) XXX_DiscardUnknown()
func (*PrimitiveId) XXX_Marshal ¶
func (m *PrimitiveId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimitiveId) XXX_Merge ¶
func (m *PrimitiveId) XXX_Merge(src proto.Message)
func (*PrimitiveId) XXX_Size ¶
func (m *PrimitiveId) XXX_Size() int
func (*PrimitiveId) XXX_Unmarshal ¶
func (m *PrimitiveId) XXX_Unmarshal(b []byte) error
type RegisterPrimitiveRequest ¶
type RegisterPrimitiveRequest struct { PrimitiveID PrimitiveId `protobuf:"bytes,1,opt,name=primitive_id,json=primitiveId,proto3" json:"primitive_id"` Address PrimitiveAddress `protobuf:"bytes,2,opt,name=address,proto3" json:"address"` }
func (*RegisterPrimitiveRequest) Descriptor ¶
func (*RegisterPrimitiveRequest) Descriptor() ([]byte, []int)
func (*RegisterPrimitiveRequest) GetAddress ¶
func (m *RegisterPrimitiveRequest) GetAddress() PrimitiveAddress
func (*RegisterPrimitiveRequest) GetPrimitiveID ¶
func (m *RegisterPrimitiveRequest) GetPrimitiveID() PrimitiveId
func (*RegisterPrimitiveRequest) Marshal ¶
func (m *RegisterPrimitiveRequest) Marshal() (dAtA []byte, err error)
func (*RegisterPrimitiveRequest) MarshalTo ¶
func (m *RegisterPrimitiveRequest) MarshalTo(dAtA []byte) (int, error)
func (*RegisterPrimitiveRequest) MarshalToSizedBuffer ¶
func (m *RegisterPrimitiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegisterPrimitiveRequest) ProtoMessage ¶
func (*RegisterPrimitiveRequest) ProtoMessage()
func (*RegisterPrimitiveRequest) Reset ¶
func (m *RegisterPrimitiveRequest) Reset()
func (*RegisterPrimitiveRequest) Size ¶
func (m *RegisterPrimitiveRequest) Size() (n int)
func (*RegisterPrimitiveRequest) String ¶
func (m *RegisterPrimitiveRequest) String() string
func (*RegisterPrimitiveRequest) Unmarshal ¶
func (m *RegisterPrimitiveRequest) Unmarshal(dAtA []byte) error
func (*RegisterPrimitiveRequest) XXX_DiscardUnknown ¶
func (m *RegisterPrimitiveRequest) XXX_DiscardUnknown()
func (*RegisterPrimitiveRequest) XXX_Marshal ¶
func (m *RegisterPrimitiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterPrimitiveRequest) XXX_Merge ¶
func (m *RegisterPrimitiveRequest) XXX_Merge(src proto.Message)
func (*RegisterPrimitiveRequest) XXX_Size ¶
func (m *RegisterPrimitiveRequest) XXX_Size() int
func (*RegisterPrimitiveRequest) XXX_Unmarshal ¶
func (m *RegisterPrimitiveRequest) XXX_Unmarshal(b []byte) error
type RegisterPrimitiveResponse ¶
type RegisterPrimitiveResponse struct { }
func (*RegisterPrimitiveResponse) Descriptor ¶
func (*RegisterPrimitiveResponse) Descriptor() ([]byte, []int)
func (*RegisterPrimitiveResponse) Marshal ¶
func (m *RegisterPrimitiveResponse) Marshal() (dAtA []byte, err error)
func (*RegisterPrimitiveResponse) MarshalTo ¶
func (m *RegisterPrimitiveResponse) MarshalTo(dAtA []byte) (int, error)
func (*RegisterPrimitiveResponse) MarshalToSizedBuffer ¶
func (m *RegisterPrimitiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegisterPrimitiveResponse) ProtoMessage ¶
func (*RegisterPrimitiveResponse) ProtoMessage()
func (*RegisterPrimitiveResponse) Reset ¶
func (m *RegisterPrimitiveResponse) Reset()
func (*RegisterPrimitiveResponse) Size ¶
func (m *RegisterPrimitiveResponse) Size() (n int)
func (*RegisterPrimitiveResponse) String ¶
func (m *RegisterPrimitiveResponse) String() string
func (*RegisterPrimitiveResponse) Unmarshal ¶
func (m *RegisterPrimitiveResponse) Unmarshal(dAtA []byte) error
func (*RegisterPrimitiveResponse) XXX_DiscardUnknown ¶
func (m *RegisterPrimitiveResponse) XXX_DiscardUnknown()
func (*RegisterPrimitiveResponse) XXX_Marshal ¶
func (m *RegisterPrimitiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterPrimitiveResponse) XXX_Merge ¶
func (m *RegisterPrimitiveResponse) XXX_Merge(src proto.Message)
func (*RegisterPrimitiveResponse) XXX_Size ¶
func (m *RegisterPrimitiveResponse) XXX_Size() int
func (*RegisterPrimitiveResponse) XXX_Unmarshal ¶
func (m *RegisterPrimitiveResponse) XXX_Unmarshal(b []byte) error
type UnimplementedBrokerServer ¶
type UnimplementedBrokerServer struct { }
UnimplementedBrokerServer can be embedded to have forward compatible implementations.
func (*UnimplementedBrokerServer) LookupPrimitive ¶
func (*UnimplementedBrokerServer) LookupPrimitive(ctx context.Context, req *LookupPrimitiveRequest) (*LookupPrimitiveResponse, error)
func (*UnimplementedBrokerServer) RegisterPrimitive ¶
func (*UnimplementedBrokerServer) RegisterPrimitive(ctx context.Context, req *RegisterPrimitiveRequest) (*RegisterPrimitiveResponse, error)
func (*UnimplementedBrokerServer) UnregisterPrimitive ¶
func (*UnimplementedBrokerServer) UnregisterPrimitive(ctx context.Context, req *UnregisterPrimitiveRequest) (*UnregisterPrimitiveResponse, error)
type UnregisterPrimitiveRequest ¶
type UnregisterPrimitiveRequest struct {
PrimitiveID PrimitiveId `protobuf:"bytes,1,opt,name=primitive_id,json=primitiveId,proto3" json:"primitive_id"`
}
func (*UnregisterPrimitiveRequest) Descriptor ¶
func (*UnregisterPrimitiveRequest) Descriptor() ([]byte, []int)
func (*UnregisterPrimitiveRequest) GetPrimitiveID ¶
func (m *UnregisterPrimitiveRequest) GetPrimitiveID() PrimitiveId
func (*UnregisterPrimitiveRequest) Marshal ¶
func (m *UnregisterPrimitiveRequest) Marshal() (dAtA []byte, err error)
func (*UnregisterPrimitiveRequest) MarshalTo ¶
func (m *UnregisterPrimitiveRequest) MarshalTo(dAtA []byte) (int, error)
func (*UnregisterPrimitiveRequest) MarshalToSizedBuffer ¶
func (m *UnregisterPrimitiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnregisterPrimitiveRequest) ProtoMessage ¶
func (*UnregisterPrimitiveRequest) ProtoMessage()
func (*UnregisterPrimitiveRequest) Reset ¶
func (m *UnregisterPrimitiveRequest) Reset()
func (*UnregisterPrimitiveRequest) Size ¶
func (m *UnregisterPrimitiveRequest) Size() (n int)
func (*UnregisterPrimitiveRequest) String ¶
func (m *UnregisterPrimitiveRequest) String() string
func (*UnregisterPrimitiveRequest) Unmarshal ¶
func (m *UnregisterPrimitiveRequest) Unmarshal(dAtA []byte) error
func (*UnregisterPrimitiveRequest) XXX_DiscardUnknown ¶
func (m *UnregisterPrimitiveRequest) XXX_DiscardUnknown()
func (*UnregisterPrimitiveRequest) XXX_Marshal ¶
func (m *UnregisterPrimitiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UnregisterPrimitiveRequest) XXX_Merge ¶
func (m *UnregisterPrimitiveRequest) XXX_Merge(src proto.Message)
func (*UnregisterPrimitiveRequest) XXX_Size ¶
func (m *UnregisterPrimitiveRequest) XXX_Size() int
func (*UnregisterPrimitiveRequest) XXX_Unmarshal ¶
func (m *UnregisterPrimitiveRequest) XXX_Unmarshal(b []byte) error
type UnregisterPrimitiveResponse ¶
type UnregisterPrimitiveResponse struct { }
func (*UnregisterPrimitiveResponse) Descriptor ¶
func (*UnregisterPrimitiveResponse) Descriptor() ([]byte, []int)
func (*UnregisterPrimitiveResponse) Marshal ¶
func (m *UnregisterPrimitiveResponse) Marshal() (dAtA []byte, err error)
func (*UnregisterPrimitiveResponse) MarshalTo ¶
func (m *UnregisterPrimitiveResponse) MarshalTo(dAtA []byte) (int, error)
func (*UnregisterPrimitiveResponse) MarshalToSizedBuffer ¶
func (m *UnregisterPrimitiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnregisterPrimitiveResponse) ProtoMessage ¶
func (*UnregisterPrimitiveResponse) ProtoMessage()
func (*UnregisterPrimitiveResponse) Reset ¶
func (m *UnregisterPrimitiveResponse) Reset()
func (*UnregisterPrimitiveResponse) Size ¶
func (m *UnregisterPrimitiveResponse) Size() (n int)
func (*UnregisterPrimitiveResponse) String ¶
func (m *UnregisterPrimitiveResponse) String() string
func (*UnregisterPrimitiveResponse) Unmarshal ¶
func (m *UnregisterPrimitiveResponse) Unmarshal(dAtA []byte) error
func (*UnregisterPrimitiveResponse) XXX_DiscardUnknown ¶
func (m *UnregisterPrimitiveResponse) XXX_DiscardUnknown()
func (*UnregisterPrimitiveResponse) XXX_Marshal ¶
func (m *UnregisterPrimitiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UnregisterPrimitiveResponse) XXX_Merge ¶
func (m *UnregisterPrimitiveResponse) XXX_Merge(src proto.Message)
func (*UnregisterPrimitiveResponse) XXX_Size ¶
func (m *UnregisterPrimitiveResponse) XXX_Size() int
func (*UnregisterPrimitiveResponse) XXX_Unmarshal ¶
func (m *UnregisterPrimitiveResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.