chats_v1beta

Documentation

Index

• func NewChatsServiceServer(bdb bun.IDB, nsc *nats.Conn, logger logging.Logger) (chats_pb.ChatsServiceServer, error)
• type ChatsServiceServer
  • func (s *ChatsServiceServer) Authorize(ctx context.Context, _ string) error
  • func (s *ChatsServiceServer) DescribeSession(ctx context.Context, req *chats_pb.DescribeSessionRequest) (*chats_pb.DescribeSessionResponse, error)
  • func (s *ChatsServiceServer) ListRecords(ctx context.Context, req *chats_pb.ListRecordsRequest) (*chats_pb.ListRecordsResponse, error)
  • func (s *ChatsServiceServer) ListSessions(ctx context.Context, req *chats_pb.ListSessionsRequest) (*chats_pb.ListSessionsResponse, error)
  • func (s *ChatsServiceServer) ReadSession(ctx context.Context, req *chats_pb.ReadSessionRequest) (*chats_pb.ReadSessionResponse, error)
  • func (s *ChatsServiceServer) RegisterGatewayClient(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
  • func (s *ChatsServiceServer) RegisterServerService(reg grpc.ServiceRegistrar)
  • func (s *ChatsServiceServer) SendRecord(ctx context.Context, req *chats_pb.SendRecordRequest) (*chats_pb.SendRecordResponse, error)
  • func (s *ChatsServiceServer) WatchRecords(_ *chats_pb.WatchRecordsRequest, srv chats_pb.ChatsService_WatchRecordsServer) error

Functions

func NewChatsServiceServer

func NewChatsServiceServer(bdb bun.IDB, nsc *nats.Conn, logger logging.Logger) (chats_pb.ChatsServiceServer, error)

Types

type ChatsServiceServer

type ChatsServiceServer struct {
	chats_pb.UnimplementedChatsServiceServer
	// contains filtered or unexported fields
}

func (*ChatsServiceServer) Authorize

func (s *ChatsServiceServer) Authorize(ctx context.Context, _ string) error

func (*ChatsServiceServer) DescribeSession

func (s *ChatsServiceServer) DescribeSession(ctx context.Context, req *chats_pb.DescribeSessionRequest) (*chats_pb.DescribeSessionResponse, error)

func (*ChatsServiceServer) ListRecords

func (s *ChatsServiceServer) ListRecords(ctx context.Context, req *chats_pb.ListRecordsRequest) (*chats_pb.ListRecordsResponse, error)

func (*ChatsServiceServer) ListSessions

func (s *ChatsServiceServer) ListSessions(ctx context.Context, req *chats_pb.ListSessionsRequest) (*chats_pb.ListSessionsResponse, error)

func (*ChatsServiceServer) ReadSession

func (s *ChatsServiceServer) ReadSession(ctx context.Context, req *chats_pb.ReadSessionRequest) (*chats_pb.ReadSessionResponse, error)

func (*ChatsServiceServer) RegisterGatewayClient

func (s *ChatsServiceServer) RegisterGatewayClient(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

func (*ChatsServiceServer) RegisterServerService

func (s *ChatsServiceServer) RegisterServerService(reg grpc.ServiceRegistrar)

func (*ChatsServiceServer) SendRecord

func (s *ChatsServiceServer) SendRecord(ctx context.Context, req *chats_pb.SendRecordRequest) (*chats_pb.SendRecordResponse, error)

func (*ChatsServiceServer) WatchRecords

func (s *ChatsServiceServer) WatchRecords(_ *chats_pb.WatchRecordsRequest, srv chats_pb.ChatsService_WatchRecordsServer) error