Kaien
00e8f9b190
Extend AnswerJobState with RUNNING/CANCELLED/EXPIRED (values 5-7, backward compatible). Add AgentRequest/AgentResponse/AgentToolLoopOptions/ AgentResponseContract/AgentUsage/AgentOutputFormat and Cancel* messages. Existing RPCs unchanged. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
412 lines
17 KiB
Go
412 lines
17 KiB
Go
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||
// versions:
|
||
// - protoc-gen-go-grpc v1.6.1
|
||
// - protoc v7.34.0
|
||
// source: ai.proto
|
||
|
||
package proto
|
||
|
||
import (
|
||
context "context"
|
||
grpc "google.golang.org/grpc"
|
||
codes "google.golang.org/grpc/codes"
|
||
status "google.golang.org/grpc/status"
|
||
)
|
||
|
||
// This is a compile-time assertion to ensure that this generated file
|
||
// is compatible with the grpc package it is being compiled against.
|
||
// Requires gRPC-Go v1.64.0 or later.
|
||
const _ = grpc.SupportPackageIsVersion9
|
||
|
||
const (
|
||
AIService_RunAgent_FullMethodName = "/ai.AIService/RunAgent"
|
||
AIService_CancelAnswerJob_FullMethodName = "/ai.AIService/CancelAnswerJob"
|
||
AIService_GenerateAnswer_FullMethodName = "/ai.AIService/GenerateAnswer"
|
||
AIService_GenerateStateless_FullMethodName = "/ai.AIService/GenerateStateless"
|
||
AIService_HealthCheck_FullMethodName = "/ai.AIService/HealthCheck"
|
||
AIService_CreateSession_FullMethodName = "/ai.AIService/CreateSession"
|
||
AIService_AskInSession_FullMethodName = "/ai.AIService/AskInSession"
|
||
AIService_GetAnswerJob_FullMethodName = "/ai.AIService/GetAnswerJob"
|
||
)
|
||
|
||
// AIServiceClient is the client API for AIService 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.
|
||
//
|
||
// AIService - основной сервис для работы с AI
|
||
type AIServiceClient interface {
|
||
// RunAgent — надёжный агентный вызов с серверной фильтрацией tools и deferred
|
||
// jobs. Требует service-to-service авторизации.
|
||
RunAgent(ctx context.Context, in *AgentRequest, opts ...grpc.CallOption) (*AgentResponse, error)
|
||
// CancelAnswerJob отменяет отложенную job (идемпотентно). Требует авторизации.
|
||
CancelAnswerJob(ctx context.Context, in *CancelAnswerJobRequest, opts ...grpc.CallOption) (*CancelAnswerJobResponse, error)
|
||
// GenerateAnswer генерирует ответ на запрос
|
||
GenerateAnswer(ctx context.Context, in *AIRequest, opts ...grpc.CallOption) (*AIResponse, error)
|
||
// GenerateStateless генерирует ответ из массива messages (system+history+user)
|
||
GenerateStateless(ctx context.Context, in *StatelessRequest, opts ...grpc.CallOption) (*AIResponse, error)
|
||
// HealthCheck проверяет здоровье сервиса
|
||
HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
|
||
// CreateSession созда новую AI сессию
|
||
CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error)
|
||
// AskInSession отправляет запрос в рамках существующей сессии
|
||
AskInSession(ctx context.Context, in *AskInSessionRequest, opts ...grpc.CallOption) (*SessionStatusResponse, error)
|
||
// GetAnswerJob возвращает статус отложенной генерации ответа (когда GenerateAnswer
|
||
// вернул status=PENDING). Клиент поллит его до DONE/FAILED и постит финал.
|
||
GetAnswerJob(ctx context.Context, in *GetAnswerJobRequest, opts ...grpc.CallOption) (*AnswerJobResponse, error)
|
||
}
|
||
|
||
type aIServiceClient struct {
|
||
cc grpc.ClientConnInterface
|
||
}
|
||
|
||
func NewAIServiceClient(cc grpc.ClientConnInterface) AIServiceClient {
|
||
return &aIServiceClient{cc}
|
||
}
|
||
|
||
func (c *aIServiceClient) RunAgent(ctx context.Context, in *AgentRequest, opts ...grpc.CallOption) (*AgentResponse, error) {
|
||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||
out := new(AgentResponse)
|
||
err := c.cc.Invoke(ctx, AIService_RunAgent_FullMethodName, in, out, cOpts...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return out, nil
|
||
}
|
||
|
||
func (c *aIServiceClient) CancelAnswerJob(ctx context.Context, in *CancelAnswerJobRequest, opts ...grpc.CallOption) (*CancelAnswerJobResponse, error) {
|
||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||
out := new(CancelAnswerJobResponse)
|
||
err := c.cc.Invoke(ctx, AIService_CancelAnswerJob_FullMethodName, in, out, cOpts...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return out, nil
|
||
}
|
||
|
||
func (c *aIServiceClient) GenerateAnswer(ctx context.Context, in *AIRequest, opts ...grpc.CallOption) (*AIResponse, error) {
|
||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||
out := new(AIResponse)
|
||
err := c.cc.Invoke(ctx, AIService_GenerateAnswer_FullMethodName, in, out, cOpts...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return out, nil
|
||
}
|
||
|
||
func (c *aIServiceClient) GenerateStateless(ctx context.Context, in *StatelessRequest, opts ...grpc.CallOption) (*AIResponse, error) {
|
||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||
out := new(AIResponse)
|
||
err := c.cc.Invoke(ctx, AIService_GenerateStateless_FullMethodName, in, out, cOpts...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return out, nil
|
||
}
|
||
|
||
func (c *aIServiceClient) HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error) {
|
||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||
out := new(HealthCheckResponse)
|
||
err := c.cc.Invoke(ctx, AIService_HealthCheck_FullMethodName, in, out, cOpts...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return out, nil
|
||
}
|
||
|
||
func (c *aIServiceClient) CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error) {
|
||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||
out := new(CreateSessionResponse)
|
||
err := c.cc.Invoke(ctx, AIService_CreateSession_FullMethodName, in, out, cOpts...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return out, nil
|
||
}
|
||
|
||
func (c *aIServiceClient) AskInSession(ctx context.Context, in *AskInSessionRequest, opts ...grpc.CallOption) (*SessionStatusResponse, error) {
|
||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||
out := new(SessionStatusResponse)
|
||
err := c.cc.Invoke(ctx, AIService_AskInSession_FullMethodName, in, out, cOpts...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return out, nil
|
||
}
|
||
|
||
func (c *aIServiceClient) GetAnswerJob(ctx context.Context, in *GetAnswerJobRequest, opts ...grpc.CallOption) (*AnswerJobResponse, error) {
|
||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||
out := new(AnswerJobResponse)
|
||
err := c.cc.Invoke(ctx, AIService_GetAnswerJob_FullMethodName, in, out, cOpts...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return out, nil
|
||
}
|
||
|
||
// AIServiceServer is the server API for AIService service.
|
||
// All implementations must embed UnimplementedAIServiceServer
|
||
// for forward compatibility.
|
||
//
|
||
// AIService - основной сервис для работы с AI
|
||
type AIServiceServer interface {
|
||
// RunAgent — надёжный агентный вызов с серверной фильтрацией tools и deferred
|
||
// jobs. Требует service-to-service авторизации.
|
||
RunAgent(context.Context, *AgentRequest) (*AgentResponse, error)
|
||
// CancelAnswerJob отменяет отложенную job (идемпотентно). Требует авторизации.
|
||
CancelAnswerJob(context.Context, *CancelAnswerJobRequest) (*CancelAnswerJobResponse, error)
|
||
// GenerateAnswer генерирует ответ на запрос
|
||
GenerateAnswer(context.Context, *AIRequest) (*AIResponse, error)
|
||
// GenerateStateless генерирует ответ из массива messages (system+history+user)
|
||
GenerateStateless(context.Context, *StatelessRequest) (*AIResponse, error)
|
||
// HealthCheck проверяет здоровье сервиса
|
||
HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
|
||
// CreateSession созда новую AI сессию
|
||
CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)
|
||
// AskInSession отправляет запрос в рамках существующей сессии
|
||
AskInSession(context.Context, *AskInSessionRequest) (*SessionStatusResponse, error)
|
||
// GetAnswerJob возвращает статус отложенной генерации ответа (когда GenerateAnswer
|
||
// вернул status=PENDING). Клиент поллит его до DONE/FAILED и постит финал.
|
||
GetAnswerJob(context.Context, *GetAnswerJobRequest) (*AnswerJobResponse, error)
|
||
mustEmbedUnimplementedAIServiceServer()
|
||
}
|
||
|
||
// UnimplementedAIServiceServer must be embedded to have
|
||
// forward compatible implementations.
|
||
//
|
||
// NOTE: this should be embedded by value instead of pointer to avoid a nil
|
||
// pointer dereference when methods are called.
|
||
type UnimplementedAIServiceServer struct{}
|
||
|
||
func (UnimplementedAIServiceServer) RunAgent(context.Context, *AgentRequest) (*AgentResponse, error) {
|
||
return nil, status.Error(codes.Unimplemented, "method RunAgent not implemented")
|
||
}
|
||
func (UnimplementedAIServiceServer) CancelAnswerJob(context.Context, *CancelAnswerJobRequest) (*CancelAnswerJobResponse, error) {
|
||
return nil, status.Error(codes.Unimplemented, "method CancelAnswerJob not implemented")
|
||
}
|
||
func (UnimplementedAIServiceServer) GenerateAnswer(context.Context, *AIRequest) (*AIResponse, error) {
|
||
return nil, status.Error(codes.Unimplemented, "method GenerateAnswer not implemented")
|
||
}
|
||
func (UnimplementedAIServiceServer) GenerateStateless(context.Context, *StatelessRequest) (*AIResponse, error) {
|
||
return nil, status.Error(codes.Unimplemented, "method GenerateStateless not implemented")
|
||
}
|
||
func (UnimplementedAIServiceServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error) {
|
||
return nil, status.Error(codes.Unimplemented, "method HealthCheck not implemented")
|
||
}
|
||
func (UnimplementedAIServiceServer) CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error) {
|
||
return nil, status.Error(codes.Unimplemented, "method CreateSession not implemented")
|
||
}
|
||
func (UnimplementedAIServiceServer) AskInSession(context.Context, *AskInSessionRequest) (*SessionStatusResponse, error) {
|
||
return nil, status.Error(codes.Unimplemented, "method AskInSession not implemented")
|
||
}
|
||
func (UnimplementedAIServiceServer) GetAnswerJob(context.Context, *GetAnswerJobRequest) (*AnswerJobResponse, error) {
|
||
return nil, status.Error(codes.Unimplemented, "method GetAnswerJob not implemented")
|
||
}
|
||
func (UnimplementedAIServiceServer) mustEmbedUnimplementedAIServiceServer() {}
|
||
func (UnimplementedAIServiceServer) testEmbeddedByValue() {}
|
||
|
||
// UnsafeAIServiceServer may be embedded to opt out of forward compatibility for this service.
|
||
// Use of this interface is not recommended, as added methods to AIServiceServer will
|
||
// result in compilation errors.
|
||
type UnsafeAIServiceServer interface {
|
||
mustEmbedUnimplementedAIServiceServer()
|
||
}
|
||
|
||
func RegisterAIServiceServer(s grpc.ServiceRegistrar, srv AIServiceServer) {
|
||
// If the following call panics, it indicates UnimplementedAIServiceServer was
|
||
// embedded by pointer and is nil. This will cause panics if an
|
||
// unimplemented method is ever invoked, so we test this at initialization
|
||
// time to prevent it from happening at runtime later due to I/O.
|
||
if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
|
||
t.testEmbeddedByValue()
|
||
}
|
||
s.RegisterService(&AIService_ServiceDesc, srv)
|
||
}
|
||
|
||
func _AIService_RunAgent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||
in := new(AgentRequest)
|
||
if err := dec(in); err != nil {
|
||
return nil, err
|
||
}
|
||
if interceptor == nil {
|
||
return srv.(AIServiceServer).RunAgent(ctx, in)
|
||
}
|
||
info := &grpc.UnaryServerInfo{
|
||
Server: srv,
|
||
FullMethod: AIService_RunAgent_FullMethodName,
|
||
}
|
||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||
return srv.(AIServiceServer).RunAgent(ctx, req.(*AgentRequest))
|
||
}
|
||
return interceptor(ctx, in, info, handler)
|
||
}
|
||
|
||
func _AIService_CancelAnswerJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||
in := new(CancelAnswerJobRequest)
|
||
if err := dec(in); err != nil {
|
||
return nil, err
|
||
}
|
||
if interceptor == nil {
|
||
return srv.(AIServiceServer).CancelAnswerJob(ctx, in)
|
||
}
|
||
info := &grpc.UnaryServerInfo{
|
||
Server: srv,
|
||
FullMethod: AIService_CancelAnswerJob_FullMethodName,
|
||
}
|
||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||
return srv.(AIServiceServer).CancelAnswerJob(ctx, req.(*CancelAnswerJobRequest))
|
||
}
|
||
return interceptor(ctx, in, info, handler)
|
||
}
|
||
|
||
func _AIService_GenerateAnswer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||
in := new(AIRequest)
|
||
if err := dec(in); err != nil {
|
||
return nil, err
|
||
}
|
||
if interceptor == nil {
|
||
return srv.(AIServiceServer).GenerateAnswer(ctx, in)
|
||
}
|
||
info := &grpc.UnaryServerInfo{
|
||
Server: srv,
|
||
FullMethod: AIService_GenerateAnswer_FullMethodName,
|
||
}
|
||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||
return srv.(AIServiceServer).GenerateAnswer(ctx, req.(*AIRequest))
|
||
}
|
||
return interceptor(ctx, in, info, handler)
|
||
}
|
||
|
||
func _AIService_GenerateStateless_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||
in := new(StatelessRequest)
|
||
if err := dec(in); err != nil {
|
||
return nil, err
|
||
}
|
||
if interceptor == nil {
|
||
return srv.(AIServiceServer).GenerateStateless(ctx, in)
|
||
}
|
||
info := &grpc.UnaryServerInfo{
|
||
Server: srv,
|
||
FullMethod: AIService_GenerateStateless_FullMethodName,
|
||
}
|
||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||
return srv.(AIServiceServer).GenerateStateless(ctx, req.(*StatelessRequest))
|
||
}
|
||
return interceptor(ctx, in, info, handler)
|
||
}
|
||
|
||
func _AIService_HealthCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||
in := new(HealthCheckRequest)
|
||
if err := dec(in); err != nil {
|
||
return nil, err
|
||
}
|
||
if interceptor == nil {
|
||
return srv.(AIServiceServer).HealthCheck(ctx, in)
|
||
}
|
||
info := &grpc.UnaryServerInfo{
|
||
Server: srv,
|
||
FullMethod: AIService_HealthCheck_FullMethodName,
|
||
}
|
||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||
return srv.(AIServiceServer).HealthCheck(ctx, req.(*HealthCheckRequest))
|
||
}
|
||
return interceptor(ctx, in, info, handler)
|
||
}
|
||
|
||
func _AIService_CreateSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||
in := new(CreateSessionRequest)
|
||
if err := dec(in); err != nil {
|
||
return nil, err
|
||
}
|
||
if interceptor == nil {
|
||
return srv.(AIServiceServer).CreateSession(ctx, in)
|
||
}
|
||
info := &grpc.UnaryServerInfo{
|
||
Server: srv,
|
||
FullMethod: AIService_CreateSession_FullMethodName,
|
||
}
|
||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||
return srv.(AIServiceServer).CreateSession(ctx, req.(*CreateSessionRequest))
|
||
}
|
||
return interceptor(ctx, in, info, handler)
|
||
}
|
||
|
||
func _AIService_AskInSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||
in := new(AskInSessionRequest)
|
||
if err := dec(in); err != nil {
|
||
return nil, err
|
||
}
|
||
if interceptor == nil {
|
||
return srv.(AIServiceServer).AskInSession(ctx, in)
|
||
}
|
||
info := &grpc.UnaryServerInfo{
|
||
Server: srv,
|
||
FullMethod: AIService_AskInSession_FullMethodName,
|
||
}
|
||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||
return srv.(AIServiceServer).AskInSession(ctx, req.(*AskInSessionRequest))
|
||
}
|
||
return interceptor(ctx, in, info, handler)
|
||
}
|
||
|
||
func _AIService_GetAnswerJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||
in := new(GetAnswerJobRequest)
|
||
if err := dec(in); err != nil {
|
||
return nil, err
|
||
}
|
||
if interceptor == nil {
|
||
return srv.(AIServiceServer).GetAnswerJob(ctx, in)
|
||
}
|
||
info := &grpc.UnaryServerInfo{
|
||
Server: srv,
|
||
FullMethod: AIService_GetAnswerJob_FullMethodName,
|
||
}
|
||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||
return srv.(AIServiceServer).GetAnswerJob(ctx, req.(*GetAnswerJobRequest))
|
||
}
|
||
return interceptor(ctx, in, info, handler)
|
||
}
|
||
|
||
// AIService_ServiceDesc is the grpc.ServiceDesc for AIService service.
|
||
// It's only intended for direct use with grpc.RegisterService,
|
||
// and not to be introspected or modified (even as a copy)
|
||
var AIService_ServiceDesc = grpc.ServiceDesc{
|
||
ServiceName: "ai.AIService",
|
||
HandlerType: (*AIServiceServer)(nil),
|
||
Methods: []grpc.MethodDesc{
|
||
{
|
||
MethodName: "RunAgent",
|
||
Handler: _AIService_RunAgent_Handler,
|
||
},
|
||
{
|
||
MethodName: "CancelAnswerJob",
|
||
Handler: _AIService_CancelAnswerJob_Handler,
|
||
},
|
||
{
|
||
MethodName: "GenerateAnswer",
|
||
Handler: _AIService_GenerateAnswer_Handler,
|
||
},
|
||
{
|
||
MethodName: "GenerateStateless",
|
||
Handler: _AIService_GenerateStateless_Handler,
|
||
},
|
||
{
|
||
MethodName: "HealthCheck",
|
||
Handler: _AIService_HealthCheck_Handler,
|
||
},
|
||
{
|
||
MethodName: "CreateSession",
|
||
Handler: _AIService_CreateSession_Handler,
|
||
},
|
||
{
|
||
MethodName: "AskInSession",
|
||
Handler: _AIService_AskInSession_Handler,
|
||
},
|
||
{
|
||
MethodName: "GetAnswerJob",
|
||
Handler: _AIService_GetAnswerJob_Handler,
|
||
},
|
||
},
|
||
Streams: []grpc.StreamDesc{},
|
||
Metadata: "ai.proto",
|
||
}
|