ordering

package
v0.2.1 Latest Latest
Warning

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

Go to latest
Published: Jul 20, 2020 License: MIT Imports: 10 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_ordering_ordering_proto protoreflect.FileDescriptor

Functions

func RegisterGorumsServer

func RegisterGorumsServer(s *grpc.Server, srv GorumsServer)

Types

type GorumsClient

type GorumsClient interface {
	// NodeStream is a stream that connects a client to a Node.
	// The messages that are sent on the stream contain both Metadata
	// and an application-specific message.
	NodeStream(ctx context.Context, opts ...grpc.CallOption) (Gorums_NodeStreamClient, error)
}

GorumsClient is the client API for Gorums service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGorumsClient

func NewGorumsClient(cc grpc.ClientConnInterface) GorumsClient

type GorumsServer

type GorumsServer interface {
	// NodeStream is a stream that connects a client to a Node.
	// The messages that are sent on the stream contain both Metadata
	// and an application-specific message.
	NodeStream(Gorums_NodeStreamServer) error
	// contains filtered or unexported methods
}

GorumsServer is the server API for Gorums service. All implementations must embed UnimplementedGorumsServer for forward compatibility

type Gorums_NodeStreamClient

type Gorums_NodeStreamClient interface {
	Send(*Metadata) error
	Recv() (*Metadata, error)
	grpc.ClientStream
}

type Gorums_NodeStreamServer

type Gorums_NodeStreamServer interface {
	Send(*Metadata) error
	Recv() (*Metadata, error)
	grpc.ServerStream
}

type Metadata

type Metadata struct {
	MessageID uint64         `protobuf:"varint,1,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	MethodID  int32          `protobuf:"varint,2,opt,name=MethodID,proto3" json:"MethodID,omitempty"`
	Status    *status.Status `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"`
	// contains filtered or unexported fields
}

Metadata is sent together with application-specific message types, and contains information necessary for Gorums to handle the messages.

func (*Metadata) Descriptor deprecated

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetMessageID

func (x *Metadata) GetMessageID() uint64

func (*Metadata) GetMethodID

func (x *Metadata) GetMethodID() int32

func (*Metadata) GetStatus added in v0.2.1

func (x *Metadata) GetStatus() *status.Status

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset

func (x *Metadata) Reset()

func (*Metadata) String

func (x *Metadata) String() string

type UnimplementedGorumsServer

type UnimplementedGorumsServer struct {
}

UnimplementedGorumsServer must be embedded to have forward compatible implementations.

func (*UnimplementedGorumsServer) NodeStream

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL