server

Documentation

Index

• type GRPCServer
  • func NewGRPCServer(chatCompletionStreamUseCase chatcompletionstream.ChatCompletionUseCase, ...) *GRPCServer
  • func (g *GRPCServer) AuthInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (g *GRPCServer) Start() error

Types

type GRPCServer

type GRPCServer struct {
	ChatCompletionStreamUseCase chatcompletionstream.ChatCompletionUseCase
	ChatConfigStream            chatcompletionstream.ChatCompletionConfigInputDto
	ChatService                 service.ChatService
	Port                        string
	AuthToken                   string
	StreamChannel               chan chatcompletionstream.ChatCompletionOutputDto
}

func NewGRPCServer

func NewGRPCServer(chatCompletionStreamUseCase chatcompletionstream.ChatCompletionUseCase, chatConfigStream chatcompletionstream.ChatCompletionConfigInputDto, port, authToken string, streamChannel chan chatcompletionstream.ChatCompletionOutputDto) *GRPCServer

func (*GRPCServer) AuthInterceptor

func (g *GRPCServer) AuthInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*GRPCServer) Start

func (g *GRPCServer) Start() error