ordering

Documentation

Index

• Variables
• func RegisterGorumsServer(s grpc.ServiceRegistrar, srv GorumsServer)
• type GorumsClient
  • func NewGorumsClient(cc grpc.ClientConnInterface) GorumsClient
• type GorumsServer
• type Gorums_NodeStreamClient
• type Gorums_NodeStreamServer
• type Metadata
  • func (*Metadata) Descriptor() ([]byte, []int)
  • func (x *Metadata) GetMessageID() uint64
  • func (x *Metadata) GetMethod() string
  • func (x *Metadata) GetStatus() *status.Status
  • func (*Metadata) ProtoMessage()
  • func (x *Metadata) ProtoReflect() protoreflect.Message
  • func (x *Metadata) Reset()
  • func (x *Metadata) String() string
• type UnimplementedGorumsServer
  • func (UnimplementedGorumsServer) NodeStream(Gorums_NodeStreamServer) error
• type UnsafeGorumsServer

Variables

var File_ordering_ordering_proto protoreflect.FileDescriptor

var Gorums_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ordering.Gorums",
	HandlerType: (*GorumsServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "NodeStream",
			Handler:       _Gorums_NodeStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "ordering/ordering.proto",
}

Gorums_ServiceDesc is the grpc.ServiceDesc for Gorums service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGorumsServer

func RegisterGorumsServer(s grpc.ServiceRegistrar, 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"`
	Method    string         `protobuf:"bytes,2,opt,name=Method,proto3" json:"Method,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

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetMessageID

func (x *Metadata) GetMessageID() uint64

func (*Metadata) GetMethod

func (x *Metadata) GetMethod() string

func (*Metadata) GetStatus

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

func (UnimplementedGorumsServer) NodeStream(Gorums_NodeStreamServer) error

type UnsafeGorumsServer

type UnsafeGorumsServer interface {
	// contains filtered or unexported methods
}

UnsafeGorumsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GorumsServer will result in compilation errors.