chatterpb

package
v2.1.2+incompatible Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2020 License: MIT Imports: 9 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_chatter_proto protoreflect.FileDescriptor

Functions

func RegisterChatterServer 

func RegisterChatterServer(s *grpc.Server, srv ChatterServer)

Types

type ChatSummary 

type ChatSummary struct {

	// Message sent to the server
	Message_ string `protobuf:"bytes,1,opt,name=message_,json=message,proto3" json:"message_,omitempty"`
	// Length of the message sent
	Length int32 `protobuf:"zigzag32,2,opt,name=length,proto3" json:"length,omitempty"`
	// Time at which the message was sent
	SentAt string `protobuf:"bytes,3,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ChatSummary) Descriptor deprecated 

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

Deprecated: Use ChatSummary.ProtoReflect.Descriptor instead.

func (*ChatSummary) GetLength 

func (x *ChatSummary) GetLength() int32

func (*ChatSummary) GetMessage_ 

func (x *ChatSummary) GetMessage_() string

func (*ChatSummary) GetSentAt 

func (x *ChatSummary) GetSentAt() string

func (*ChatSummary) ProtoMessage 

func (*ChatSummary) ProtoMessage()

func (*ChatSummary) ProtoReflect 

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

func (*ChatSummary) Reset 

func (x *ChatSummary) Reset()

func (*ChatSummary) String 

func (x *ChatSummary) String() string

type ChatSummaryCollection 

type ChatSummaryCollection struct {
	Field []*ChatSummary `protobuf:"bytes,1,rep,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*ChatSummaryCollection) Descriptor deprecated 

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

Deprecated: Use ChatSummaryCollection.ProtoReflect.Descriptor instead.

func (*ChatSummaryCollection) GetField 

func (x *ChatSummaryCollection) GetField() []*ChatSummary

func (*ChatSummaryCollection) ProtoMessage 

func (*ChatSummaryCollection) ProtoMessage()

func (*ChatSummaryCollection) ProtoReflect 

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

func (*ChatSummaryCollection) Reset 

func (x *ChatSummaryCollection) Reset()

func (*ChatSummaryCollection) String 

func (x *ChatSummaryCollection) String() string

type ChatterClient 

type ChatterClient interface {
	// Creates a valid JWT token for auth to chat.
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)
	// Echoes the message sent by the client.
	Echoer(ctx context.Context, opts ...grpc.CallOption) (Chatter_EchoerClient, error)
	// Listens to the messages sent by the client.
	Listener(ctx context.Context, opts ...grpc.CallOption) (Chatter_ListenerClient, error)
	// Summarizes the chat messages sent by the client.
	Summary(ctx context.Context, opts ...grpc.CallOption) (Chatter_SummaryClient, error)
	// Subscribe to events sent when new chat messages are added.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Chatter_SubscribeClient, error)
	// Returns the chat messages sent to the server.
	History(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (Chatter_HistoryClient, error)
}

ChatterClient is the client API for Chatter service.

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

func NewChatterClient 

func NewChatterClient(cc grpc.ClientConnInterface) ChatterClient

type ChatterServer 

type ChatterServer interface {
	// Creates a valid JWT token for auth to chat.
	Login(context.Context, *LoginRequest) (*LoginResponse, error)
	// Echoes the message sent by the client.
	Echoer(Chatter_EchoerServer) error
	// Listens to the messages sent by the client.
	Listener(Chatter_ListenerServer) error
	// Summarizes the chat messages sent by the client.
	Summary(Chatter_SummaryServer) error
	// Subscribe to events sent when new chat messages are added.
	Subscribe(*SubscribeRequest, Chatter_SubscribeServer) error
	// Returns the chat messages sent to the server.
	History(*HistoryRequest, Chatter_HistoryServer) error
}

ChatterServer is the server API for Chatter service.

type Chatter_EchoerClient 

type Chatter_EchoerClient interface {
	Send(*EchoerStreamingRequest) error
	Recv() (*EchoerResponse, error)
	grpc.ClientStream
}

type Chatter_EchoerServer 

type Chatter_EchoerServer interface {
	Send(*EchoerResponse) error
	Recv() (*EchoerStreamingRequest, error)
	grpc.ServerStream
}

type Chatter_HistoryClient 

type Chatter_HistoryClient interface {
	Recv() (*HistoryResponse, error)
	grpc.ClientStream
}

type Chatter_HistoryServer 

type Chatter_HistoryServer interface {
	Send(*HistoryResponse) error
	grpc.ServerStream
}

type Chatter_ListenerClient 

type Chatter_ListenerClient interface {
	Send(*ListenerStreamingRequest) error
	CloseAndRecv() (*ListenerResponse, error)
	grpc.ClientStream
}

type Chatter_ListenerServer 

type Chatter_ListenerServer interface {
	SendAndClose(*ListenerResponse) error
	Recv() (*ListenerStreamingRequest, error)
	grpc.ServerStream
}

type Chatter_SubscribeClient 

type Chatter_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type Chatter_SubscribeServer 

type Chatter_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type Chatter_SummaryClient 

type Chatter_SummaryClient interface {
	Send(*SummaryStreamingRequest) error
	CloseAndRecv() (*ChatSummaryCollection, error)
	grpc.ClientStream
}

type Chatter_SummaryServer 

type Chatter_SummaryServer interface {
	SendAndClose(*ChatSummaryCollection) error
	Recv() (*SummaryStreamingRequest, error)
	grpc.ServerStream
}

type EchoerResponse 

type EchoerResponse struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoerResponse) Descriptor deprecated 

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

Deprecated: Use EchoerResponse.ProtoReflect.Descriptor instead.

func (*EchoerResponse) GetField 

func (x *EchoerResponse) GetField() string

func (*EchoerResponse) ProtoMessage 

func (*EchoerResponse) ProtoMessage()

func (*EchoerResponse) ProtoReflect 

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

func (*EchoerResponse) Reset 

func (x *EchoerResponse) Reset()

func (*EchoerResponse) String 

func (x *EchoerResponse) String() string

type EchoerStreamingRequest 

type EchoerStreamingRequest struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoerStreamingRequest) Descriptor deprecated 

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

Deprecated: Use EchoerStreamingRequest.ProtoReflect.Descriptor instead.

func (*EchoerStreamingRequest) GetField 

func (x *EchoerStreamingRequest) GetField() string

func (*EchoerStreamingRequest) ProtoMessage 

func (*EchoerStreamingRequest) ProtoMessage()

func (*EchoerStreamingRequest) ProtoReflect 

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

func (*EchoerStreamingRequest) Reset 

func (x *EchoerStreamingRequest) Reset()

func (*EchoerStreamingRequest) String 

func (x *EchoerStreamingRequest) String() string

type HistoryRequest 

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

func (*HistoryRequest) Descriptor deprecated 

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

Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.

func (*HistoryRequest) ProtoMessage 

func (*HistoryRequest) ProtoMessage()

func (*HistoryRequest) ProtoReflect 

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

func (*HistoryRequest) Reset 

func (x *HistoryRequest) Reset()

func (*HistoryRequest) String 

func (x *HistoryRequest) String() string

type HistoryResponse 

type HistoryResponse struct {

	// Message sent to the server
	Message_ string `protobuf:"bytes,1,opt,name=message_,json=message,proto3" json:"message_,omitempty"`
	// Length of the message sent
	Length int32 `protobuf:"zigzag32,2,opt,name=length,proto3" json:"length,omitempty"`
	// Time at which the message was sent
	SentAt string `protobuf:"bytes,3,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryResponse) Descriptor deprecated 

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

Deprecated: Use HistoryResponse.ProtoReflect.Descriptor instead.

func (*HistoryResponse) GetLength 

func (x *HistoryResponse) GetLength() int32

func (*HistoryResponse) GetMessage_ 

func (x *HistoryResponse) GetMessage_() string

func (*HistoryResponse) GetSentAt 

func (x *HistoryResponse) GetSentAt() string

func (*HistoryResponse) ProtoMessage 

func (*HistoryResponse) ProtoMessage()

func (*HistoryResponse) ProtoReflect 

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

func (*HistoryResponse) Reset 

func (x *HistoryResponse) Reset()

func (*HistoryResponse) String 

func (x *HistoryResponse) String() string

type ListenerResponse 

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

func (*ListenerResponse) Descriptor deprecated 

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

Deprecated: Use ListenerResponse.ProtoReflect.Descriptor instead.

func (*ListenerResponse) ProtoMessage 

func (*ListenerResponse) ProtoMessage()

func (*ListenerResponse) ProtoReflect 

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

func (*ListenerResponse) Reset 

func (x *ListenerResponse) Reset()

func (*ListenerResponse) String 

func (x *ListenerResponse) String() string

type ListenerStreamingRequest 

type ListenerStreamingRequest struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenerStreamingRequest) Descriptor deprecated 

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

Deprecated: Use ListenerStreamingRequest.ProtoReflect.Descriptor instead.

func (*ListenerStreamingRequest) GetField 

func (x *ListenerStreamingRequest) GetField() string

func (*ListenerStreamingRequest) ProtoMessage 

func (*ListenerStreamingRequest) ProtoMessage()

func (*ListenerStreamingRequest) ProtoReflect 

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

func (*ListenerStreamingRequest) Reset 

func (x *ListenerStreamingRequest) Reset()

func (*ListenerStreamingRequest) String 

func (x *ListenerStreamingRequest) String() string

type LoginRequest 

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

func (*LoginRequest) Descriptor deprecated 

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

Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.

func (*LoginRequest) ProtoMessage 

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect 

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

func (*LoginRequest) Reset 

func (x *LoginRequest) Reset()

func (*LoginRequest) String 

func (x *LoginRequest) String() string

type LoginResponse 

type LoginResponse struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginResponse) Descriptor deprecated 

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

Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.

func (*LoginResponse) GetField 

func (x *LoginResponse) GetField() string

func (*LoginResponse) ProtoMessage 

func (*LoginResponse) ProtoMessage()

func (*LoginResponse) ProtoReflect 

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

func (*LoginResponse) Reset 

func (x *LoginResponse) Reset()

func (*LoginResponse) String 

func (x *LoginResponse) String() string

type SubscribeRequest 

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

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

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 SubscribeResponse 

type SubscribeResponse struct {

	// Message sent to the server
	Message_ string `protobuf:"bytes,1,opt,name=message_,json=message,proto3" json:"message_,omitempty"`
	Action   string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	// Time at which the message was added
	AddedAt string `protobuf:"bytes,3,opt,name=added_at,json=addedAt,proto3" json:"added_at,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetAction 

func (x *SubscribeResponse) GetAction() string

func (*SubscribeResponse) GetAddedAt 

func (x *SubscribeResponse) GetAddedAt() string

func (*SubscribeResponse) GetMessage_ 

func (x *SubscribeResponse) GetMessage_() string

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type SummaryStreamingRequest 

type SummaryStreamingRequest struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*SummaryStreamingRequest) Descriptor deprecated 

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

Deprecated: Use SummaryStreamingRequest.ProtoReflect.Descriptor instead.

func (*SummaryStreamingRequest) GetField 

func (x *SummaryStreamingRequest) GetField() string

func (*SummaryStreamingRequest) ProtoMessage 

func (*SummaryStreamingRequest) ProtoMessage()

func (*SummaryStreamingRequest) ProtoReflect 

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

func (*SummaryStreamingRequest) Reset 

func (x *SummaryStreamingRequest) Reset()

func (*SummaryStreamingRequest) String 

func (x *SummaryStreamingRequest) String() string

type UnimplementedChatterServer 

type UnimplementedChatterServer struct {
}

UnimplementedChatterServer can be embedded to have forward compatible implementations.

func (*UnimplementedChatterServer) Echoer 

func (*UnimplementedChatterServer) Echoer(Chatter_EchoerServer) error

func (*UnimplementedChatterServer) History 

func (*UnimplementedChatterServer) History(*HistoryRequest, Chatter_HistoryServer) error

func (*UnimplementedChatterServer) Listener 

func (*UnimplementedChatterServer) Listener(Chatter_ListenerServer) error

func (*UnimplementedChatterServer) Login 

func (*UnimplementedChatterServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)

func (*UnimplementedChatterServer) Subscribe 

func (*UnimplementedChatterServer) Subscribe(*SubscribeRequest, Chatter_SubscribeServer) error

func (*UnimplementedChatterServer) Summary 

func (*UnimplementedChatterServer) Summary(Chatter_SummaryServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.