v1

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBroker        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBroker          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBroker = fmt.Errorf("proto: unexpected end of group")
)

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) MarshalTo 

func (m *PrimitiveAddress) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PrimitiveId) MarshalTo(dAtA []byte) (int, 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

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.