chittychat

Documentation

Index

• Variables
• func RegisterChittyChatServer(s grpc.ServiceRegistrar, srv ChittyChatServer)
• type ChittyChatClient
  • func NewChittyChatClient(cc grpc.ClientConnInterface) ChittyChatClient
• type ChittyChatServer
• type ChittyChat_SubscribeClient
• type ChittyChat_SubscribeServer
• type LamportTime
  • func (lamport *LamportTime) UpdateTime(recievedTime int32)
• type PublishReply
  • func (*PublishReply) Descriptor() ([]byte, []int)
  • func (*PublishReply) ProtoMessage()
  • func (x *PublishReply) ProtoReflect() protoreflect.Message
  • func (x *PublishReply) Reset()
  • func (x *PublishReply) String() string
• type PublishRequest
  • func (*PublishRequest) Descriptor() ([]byte, []int)
  • func (x *PublishRequest) GetMessage() string
  • func (x *PublishRequest) GetTime() int32
  • func (x *PublishRequest) GetUser() string
  • func (*PublishRequest) ProtoMessage()
  • func (x *PublishRequest) ProtoReflect() protoreflect.Message
  • func (x *PublishRequest) Reset()
  • func (x *PublishRequest) String() string
• type SubscribeReply
  • func (*SubscribeReply) Descriptor() ([]byte, []int)
  • func (x *SubscribeReply) GetMessage() string
  • func (x *SubscribeReply) GetTime() int32
  • func (x *SubscribeReply) GetUser() string
  • func (*SubscribeReply) ProtoMessage()
  • func (x *SubscribeReply) ProtoReflect() protoreflect.Message
  • func (x *SubscribeReply) Reset()
  • func (x *SubscribeReply) String() string
• type SubscribeRequest
  • func (*SubscribeRequest) Descriptor() ([]byte, []int)
  • func (x *SubscribeRequest) GetTime() int32
  • func (x *SubscribeRequest) GetUsername() string
  • func (*SubscribeRequest) ProtoMessage()
  • func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
  • func (x *SubscribeRequest) Reset()
  • func (x *SubscribeRequest) String() string
• type UnimplementedChittyChatServer
  • func (UnimplementedChittyChatServer) Publish(context.Context, *PublishRequest) (*PublishReply, error)
  • func (UnimplementedChittyChatServer) Subscribe(*SubscribeRequest, ChittyChat_SubscribeServer) error
• type UnsafeChittyChatServer

Variables

var ChittyChat_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chittychat.ChittyChat",
	HandlerType: (*ChittyChatServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _ChittyChat_Publish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _ChittyChat_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "chittychat.proto",
}

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

var File_chittychat_proto protoreflect.FileDescriptor

Functions

func RegisterChittyChatServer

func RegisterChittyChatServer(s grpc.ServiceRegistrar, srv ChittyChatServer)

Types

type ChittyChatClient

type ChittyChatClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (ChittyChat_SubscribeClient, error)
}

ChittyChatClient is the client API for ChittyChat 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 NewChittyChatClient

func NewChittyChatClient(cc grpc.ClientConnInterface) ChittyChatClient

type ChittyChatServer

type ChittyChatServer interface {
	Publish(context.Context, *PublishRequest) (*PublishReply, error)
	Subscribe(*SubscribeRequest, ChittyChat_SubscribeServer) error
	// contains filtered or unexported methods
}

ChittyChatServer is the server API for ChittyChat service. All implementations must embed UnimplementedChittyChatServer for forward compatibility

type ChittyChat_SubscribeClient

type ChittyChat_SubscribeClient interface {
	Recv() (*SubscribeReply, error)
	grpc.ClientStream
}

type ChittyChat_SubscribeServer

type ChittyChat_SubscribeServer interface {
	Send(*SubscribeReply) error
	grpc.ServerStream
}

type LamportTime

type LamportTime struct {
	Time  int32
	Mutex sync.Mutex
}

func (*LamportTime) UpdateTime

func (lamport *LamportTime) UpdateTime(recievedTime int32)

type PublishReply

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

func (*PublishReply) Descriptor

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

Deprecated: Use PublishReply.ProtoReflect.Descriptor instead.

func (*PublishReply) ProtoMessage

func (*PublishReply) ProtoMessage()

func (*PublishReply) ProtoReflect

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

func (*PublishReply) Reset

func (x *PublishReply) Reset()

func (*PublishReply) String

func (x *PublishReply) String() string

type PublishRequest

type PublishRequest struct {
	User    string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Time    int32  `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetMessage

func (x *PublishRequest) GetMessage() string

func (*PublishRequest) GetTime

func (x *PublishRequest) GetTime() int32

func (*PublishRequest) GetUser

func (x *PublishRequest) GetUser() string

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect

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

func (*PublishRequest) Reset

func (x *PublishRequest) Reset()

func (*PublishRequest) String

func (x *PublishRequest) String() string

type SubscribeReply

type SubscribeReply struct {
	User    string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Time    int32  `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeReply) Descriptor

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

Deprecated: Use SubscribeReply.ProtoReflect.Descriptor instead.

func (*SubscribeReply) GetMessage

func (x *SubscribeReply) GetMessage() string

func (*SubscribeReply) GetTime

func (x *SubscribeReply) GetTime() int32

func (*SubscribeReply) GetUser

func (x *SubscribeReply) GetUser() string

func (*SubscribeReply) ProtoMessage

func (*SubscribeReply) ProtoMessage()

func (*SubscribeReply) ProtoReflect

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

func (*SubscribeReply) Reset

func (x *SubscribeReply) Reset()

func (*SubscribeReply) String

func (x *SubscribeReply) String() string

type SubscribeRequest

type SubscribeRequest struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Time     int32  `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetTime

func (x *SubscribeRequest) GetTime() int32

func (*SubscribeRequest) GetUsername

func (x *SubscribeRequest) GetUsername() string

func (*SubscribeRequest) ProtoMessage

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect

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

func (*SubscribeRequest) Reset

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String

func (x *SubscribeRequest) String() string

type UnimplementedChittyChatServer

type UnimplementedChittyChatServer struct {
}

UnimplementedChittyChatServer must be embedded to have forward compatible implementations.

func (UnimplementedChittyChatServer) Publish

func (UnimplementedChittyChatServer) Publish(context.Context, *PublishRequest) (*PublishReply, error)

func (UnimplementedChittyChatServer) Subscribe

func (UnimplementedChittyChatServer) Subscribe(*SubscribeRequest, ChittyChat_SubscribeServer) error

type UnsafeChittyChatServer

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

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