ai

Documentation

Index

• Constants
• Variables
• func Close()
• func RegisterMessageServiceServer(s grpc.ServiceRegistrar, srv MessageServiceServer)
• func SendMessage(message string) (*emptypb.Empty, error)
• type MessageRequest
  • func (*MessageRequest) Descriptor() ([]byte, []int)
  • func (x *MessageRequest) GetMessage() string
  • func (*MessageRequest) ProtoMessage()
  • func (x *MessageRequest) ProtoReflect() protoreflect.Message
  • func (x *MessageRequest) Reset()
  • func (x *MessageRequest) String() string
• type MessageResponse
  • func GetMessageResponse(message *tgbotapi.Message) (*MessageResponse, error)
  • func (*MessageResponse) Descriptor() ([]byte, []int)
  • func (x *MessageResponse) GetMessage() string
  • func (*MessageResponse) ProtoMessage()
  • func (x *MessageResponse) ProtoReflect() protoreflect.Message
  • func (x *MessageResponse) Reset()
  • func (x *MessageResponse) String() string
• type MessageServiceClient
  • func NewMessageServiceClient(cc grpc.ClientConnInterface) MessageServiceClient
• type MessageServiceServer
• type UnimplementedMessageServiceServer
  • func (UnimplementedMessageServiceServer) GetResponse(context.Context, *MessageRequest) (*MessageResponse, error)
  • func (UnimplementedMessageServiceServer) Train(context.Context, *MessageRequest) (*empty.Empty, error)
• type UnsafeMessageServiceServer

Constants

const (
	AI_LOCAL_URI = "localhost:50051"
	AI_PROD_URI  = "chatbotapi:50051"
)

Variables

var File_messageservice_proto protoreflect.FileDescriptor

var MessageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "MessageService",
	HandlerType: (*MessageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetResponse",
			Handler:    _MessageService_GetResponse_Handler,
		},
		{
			MethodName: "Train",
			Handler:    _MessageService_Train_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "messageservice.proto",
}

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

var URI string

Functions

func Close

func Close()

func RegisterMessageServiceServer

func RegisterMessageServiceServer(s grpc.ServiceRegistrar, srv MessageServiceServer)

func SendMessage

func SendMessage(message string) (*emptypb.Empty, error)

Types

type MessageRequest

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

func (*MessageRequest) Descriptor

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

Deprecated: Use MessageRequest.ProtoReflect.Descriptor instead.

func (*MessageRequest) GetMessage

func (x *MessageRequest) GetMessage() string

func (*MessageRequest) ProtoMessage

func (*MessageRequest) ProtoMessage()

func (*MessageRequest) ProtoReflect

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

func (*MessageRequest) Reset

func (x *MessageRequest) Reset()

func (*MessageRequest) String

func (x *MessageRequest) String() string

type MessageResponse

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

func GetMessageResponse

func GetMessageResponse(message *tgbotapi.Message) (*MessageResponse, error)

func (*MessageResponse) Descriptor

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

Deprecated: Use MessageResponse.ProtoReflect.Descriptor instead.

func (*MessageResponse) GetMessage

func (x *MessageResponse) GetMessage() string

func (*MessageResponse) ProtoMessage

func (*MessageResponse) ProtoMessage()

func (*MessageResponse) ProtoReflect

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

func (*MessageResponse) Reset

func (x *MessageResponse) Reset()

func (*MessageResponse) String

func (x *MessageResponse) String() string

type MessageServiceClient

type MessageServiceClient interface {
	GetResponse(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageResponse, error)
	Train(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

MessageServiceClient is the client API for MessageService 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 NewMessageServiceClient

func NewMessageServiceClient(cc grpc.ClientConnInterface) MessageServiceClient

type MessageServiceServer

type MessageServiceServer interface {
	GetResponse(context.Context, *MessageRequest) (*MessageResponse, error)
	Train(context.Context, *MessageRequest) (*empty.Empty, error)
	// contains filtered or unexported methods
}

MessageServiceServer is the server API for MessageService service. All implementations must embed UnimplementedMessageServiceServer for forward compatibility

type UnimplementedMessageServiceServer

type UnimplementedMessageServiceServer struct {
}

UnimplementedMessageServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMessageServiceServer) GetResponse

func (UnimplementedMessageServiceServer) GetResponse(context.Context, *MessageRequest) (*MessageResponse, error)

func (UnimplementedMessageServiceServer) Train

func (UnimplementedMessageServiceServer) Train(context.Context, *MessageRequest) (*empty.Empty, error)

type UnsafeMessageServiceServer

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

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