api

Documentation

Index

• Variables
• func RegisterMessageQueueSeqServer(s grpc.ServiceRegistrar, srv MessageQueueSeqServer)
• type EnqueueReply
  • func (*EnqueueReply) Descriptor() ([]byte, []int)
  • func (*EnqueueReply) ProtoMessage()
  • func (x *EnqueueReply) ProtoReflect() protoreflect.Message
  • func (x *EnqueueReply) Reset()
  • func (x *EnqueueReply) String() string
• type MessageQueueSeqClient
  • func NewMessageQueueSeqClient(cc grpc.ClientConnInterface) MessageQueueSeqClient
• type MessageQueueSeqServer
• type MessageSeq
  • func (*MessageSeq) Descriptor() ([]byte, []int)
  • func (x *MessageSeq) GetClock() uint64
  • func (x *MessageSeq) GetData() string
  • func (x *MessageSeq) GetId() string
  • func (x *MessageSeq) GetSrc() string
  • func (x *MessageSeq) GetType() MessageType
  • func (*MessageSeq) ProtoMessage()
  • func (x *MessageSeq) ProtoReflect() protoreflect.Message
  • func (x *MessageSeq) Reset()
  • func (x *MessageSeq) String() string
• type MessageType
  • func (MessageType) Descriptor() protoreflect.EnumDescriptor
  • func (x MessageType) Enum() *MessageType
  • func (MessageType) EnumDescriptor() ([]byte, []int)
  • func (x MessageType) Number() protoreflect.EnumNumber
  • func (x MessageType) String() string
  • func (MessageType) Type() protoreflect.EnumType
• type UnimplementedMessageQueueSeqServer
  • func (UnimplementedMessageQueueSeqServer) Enqueue(context.Context, *MessageSeq) (*EnqueueReply, error)
• type UnsafeMessageQueueSeqServer

Variables

var (
	MessageType_name = map[int32]string{
		0: "APPLICATION",
		1: "ACK",
		2: "SYSTEM",
	}
	MessageType_value = map[string]int32{
		"APPLICATION": 0,
		"ACK":         1,
		"SYSTEM":      2,
	}
)

Enum value maps for MessageType.

var File_SeqClockService_proto protoreflect.FileDescriptor

var MessageQueueSeq_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "MessageQueueSeq",
	HandlerType: (*MessageQueueSeqServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Enqueue",
			Handler:    _MessageQueueSeq_Enqueue_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "SeqClockService.proto",
}

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

Functions

func RegisterMessageQueueSeqServer

func RegisterMessageQueueSeqServer(s grpc.ServiceRegistrar, srv MessageQueueSeqServer)

Types

type EnqueueReply

type EnqueueReply struct {
	// contains filtered or unexported fields
}

func (*EnqueueReply) Descriptor

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

Deprecated: Use EnqueueReply.ProtoReflect.Descriptor instead.

func (*EnqueueReply) ProtoMessage

func (*EnqueueReply) ProtoMessage()

func (*EnqueueReply) ProtoReflect

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

func (*EnqueueReply) Reset

func (x *EnqueueReply) Reset()

func (*EnqueueReply) String

func (x *EnqueueReply) String() string

type MessageQueueSeqClient

type MessageQueueSeqClient interface {
	Enqueue(ctx context.Context, in *MessageSeq, opts ...grpc.CallOption) (*EnqueueReply, error)
}

MessageQueueSeqClient is the client API for MessageQueueSeq 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 NewMessageQueueSeqClient

func NewMessageQueueSeqClient(cc grpc.ClientConnInterface) MessageQueueSeqClient

type MessageQueueSeqServer

type MessageQueueSeqServer interface {
	Enqueue(context.Context, *MessageSeq) (*EnqueueReply, error)
	// contains filtered or unexported methods
}

MessageQueueSeqServer is the server API for MessageQueueSeq service. All implementations must embed UnimplementedMessageQueueSeqServer for forward compatibility

type MessageSeq

type MessageSeq struct {
	Type  MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=MessageType" json:"type,omitempty"`
	Clock uint64      `protobuf:"varint,2,opt,name=clock,proto3" json:"clock,omitempty"`
	Src   string      `protobuf:"bytes,3,opt,name=src,proto3" json:"src,omitempty"`
	Id    string      `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	Data  string      `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageSeq) Descriptor

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

Deprecated: Use MessageSeq.ProtoReflect.Descriptor instead.

func (*MessageSeq) GetClock

func (x *MessageSeq) GetClock() uint64

func (*MessageSeq) GetData

func (x *MessageSeq) GetData() string

func (*MessageSeq) GetId

func (x *MessageSeq) GetId() string

func (*MessageSeq) GetSrc

func (x *MessageSeq) GetSrc() string

func (*MessageSeq) GetType

func (x *MessageSeq) GetType() MessageType

func (*MessageSeq) ProtoMessage

func (*MessageSeq) ProtoMessage()

func (*MessageSeq) ProtoReflect

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

func (*MessageSeq) Reset

func (x *MessageSeq) Reset()

func (*MessageSeq) String

func (x *MessageSeq) String() string

type MessageType

type MessageType int32

const (
	MessageType_APPLICATION MessageType = 0
	MessageType_ACK         MessageType = 1
	MessageType_SYSTEM      MessageType = 2
)

func (MessageType) Descriptor

func (MessageType) Descriptor() protoreflect.EnumDescriptor

func (MessageType) Enum

func (x MessageType) Enum() *MessageType

func (MessageType) EnumDescriptor

func (MessageType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MessageType.Descriptor instead.

func (MessageType) Number

func (x MessageType) Number() protoreflect.EnumNumber

func (MessageType) String

func (x MessageType) String() string

func (MessageType) Type

func (MessageType) Type() protoreflect.EnumType

type UnimplementedMessageQueueSeqServer

type UnimplementedMessageQueueSeqServer struct {
}

UnimplementedMessageQueueSeqServer must be embedded to have forward compatible implementations.

func (UnimplementedMessageQueueSeqServer) Enqueue

func (UnimplementedMessageQueueSeqServer) Enqueue(context.Context, *MessageSeq) (*EnqueueReply, error)

type UnsafeMessageQueueSeqServer

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

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