pb

Documentation

Index

• func RegisterNodesServer(s *grpc.Server, srv NodesServer)
• type NodesClient
  • func NewNodesClient(cc grpc.ClientConnInterface) NodesClient
• type NodesServer
• type Nodes_SyncClient
• type Nodes_SyncServer
• type SyncMessage
  • func (*SyncMessage) Descriptor() ([]byte, []int)
  • func (m *SyncMessage) GetEncoded() []byte
  • func (m *SyncMessage) GetId() string
  • func (m *SyncMessage) GetType() string
  • func (*SyncMessage) ProtoMessage()
  • func (m *SyncMessage) Reset()
  • func (m *SyncMessage) String() string
  • func (m *SyncMessage) XXX_DiscardUnknown()
  • func (m *SyncMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SyncMessage) XXX_Merge(src proto.Message)
  • func (m *SyncMessage) XXX_Size() int
  • func (m *SyncMessage) XXX_Unmarshal(b []byte) error
• type UnimplementedNodesServer
  • func (*UnimplementedNodesServer) Sync(srv Nodes_SyncServer) error

Functions

func RegisterNodesServer

func RegisterNodesServer(s *grpc.Server, srv NodesServer)

Types

type NodesClient

type NodesClient interface {
	Sync(ctx context.Context, opts ...grpc.CallOption) (Nodes_SyncClient, error)
}

NodesClient is the client API for Nodes service.

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

func NewNodesClient

func NewNodesClient(cc grpc.ClientConnInterface) NodesClient

type NodesServer

type NodesServer interface {
	Sync(Nodes_SyncServer) error
}

NodesServer is the server API for Nodes service.

type Nodes_SyncClient

type Nodes_SyncClient interface {
	Send(*SyncMessage) error
	Recv() (*SyncMessage, error)
	grpc.ClientStream
}

type Nodes_SyncServer

type Nodes_SyncServer interface {
	Send(*SyncMessage) error
	Recv() (*SyncMessage, error)
	grpc.ServerStream
}

type SyncMessage

type SyncMessage struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Encoded              []byte   `protobuf:"bytes,3,opt,name=encoded,proto3" json:"encoded,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SyncMessage) Descriptor

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

func (*SyncMessage) GetEncoded

func (m *SyncMessage) GetEncoded() []byte

func (*SyncMessage) GetId

func (m *SyncMessage) GetId() string

func (*SyncMessage) GetType

func (m *SyncMessage) GetType() string

func (*SyncMessage) ProtoMessage

func (*SyncMessage) ProtoMessage()

func (*SyncMessage) Reset

func (m *SyncMessage) Reset()

func (*SyncMessage) String

func (m *SyncMessage) String() string

func (*SyncMessage) XXX_DiscardUnknown

func (m *SyncMessage) XXX_DiscardUnknown()

func (*SyncMessage) XXX_Marshal

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

func (*SyncMessage) XXX_Merge

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

func (*SyncMessage) XXX_Size

func (m *SyncMessage) XXX_Size() int

func (*SyncMessage) XXX_Unmarshal

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

type UnimplementedNodesServer

type UnimplementedNodesServer struct {
}

UnimplementedNodesServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodesServer) Sync

func (*UnimplementedNodesServer) Sync(srv Nodes_SyncServer) error