proto

package
v0.0.0-...-b2e64aa Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AgentWorkerService_RegisterAgent_FullMethodName   = "/goautogen.api.v1.AgentWorkerService/RegisterAgent"
	AgentWorkerService_UnregisterAgent_FullMethodName = "/goautogen.api.v1.AgentWorkerService/UnregisterAgent"
	AgentWorkerService_ExecuteMessage_FullMethodName  = "/goautogen.api.v1.AgentWorkerService/ExecuteMessage"
	AgentWorkerService_StreamMessages_FullMethodName  = "/goautogen.api.v1.AgentWorkerService/StreamMessages"
	AgentWorkerService_GetAgentStatus_FullMethodName  = "/goautogen.api.v1.AgentWorkerService/GetAgentStatus"
	AgentWorkerService_ListAgents_FullMethodName      = "/goautogen.api.v1.AgentWorkerService/ListAgents"
	AgentWorkerService_SaveAgentState_FullMethodName  = "/goautogen.api.v1.AgentWorkerService/SaveAgentState"
	AgentWorkerService_LoadAgentState_FullMethodName  = "/goautogen.api.v1.AgentWorkerService/LoadAgentState"
)
View Source 
const (
	HealthService_Check_FullMethodName           = "/goautogen.api.v1.HealthService/Check"
	HealthService_Watch_FullMethodName           = "/goautogen.api.v1.HealthService/Watch"
	HealthService_GetHealthStatus_FullMethodName = "/goautogen.api.v1.HealthService/GetHealthStatus"
)
View Source 
const (
	RuntimeService_RegisterWorker_FullMethodName           = "/goautogen.api.v1.RuntimeService/RegisterWorker"
	RuntimeService_UnregisterWorker_FullMethodName         = "/goautogen.api.v1.RuntimeService/UnregisterWorker"
	RuntimeService_GetWorkerInfo_FullMethodName            = "/goautogen.api.v1.RuntimeService/GetWorkerInfo"
	RuntimeService_ListWorkers_FullMethodName              = "/goautogen.api.v1.RuntimeService/ListWorkers"
	RuntimeService_PlaceAgent_FullMethodName               = "/goautogen.api.v1.RuntimeService/PlaceAgent"
	RuntimeService_RouteMessage_FullMethodName             = "/goautogen.api.v1.RuntimeService/RouteMessage"
	RuntimeService_StartConversation_FullMethodName        = "/goautogen.api.v1.RuntimeService/StartConversation"
	RuntimeService_EndConversation_FullMethodName          = "/goautogen.api.v1.RuntimeService/EndConversation"
	RuntimeService_GetConversation_FullMethodName          = "/goautogen.api.v1.RuntimeService/GetConversation"
	RuntimeService_ListConversations_FullMethodName        = "/goautogen.api.v1.RuntimeService/ListConversations"
	RuntimeService_StreamConversationEvents_FullMethodName = "/goautogen.api.v1.RuntimeService/StreamConversationEvents"
	RuntimeService_GetRuntimeStatus_FullMethodName         = "/goautogen.api.v1.RuntimeService/GetRuntimeStatus"
)

Variables

View Source 
var (
	AgentState_name = map[int32]string{
		0: "AGENT_STATE_UNSPECIFIED",
		1: "AGENT_STATE_UNINITIALIZED",
		2: "AGENT_STATE_INITIALIZING",
		3: "AGENT_STATE_READY",
		4: "AGENT_STATE_RUNNING",
		5: "AGENT_STATE_STOPPING",
		6: "AGENT_STATE_STOPPED",
		7: "AGENT_STATE_ERROR",
	}
	AgentState_value = map[string]int32{
		"AGENT_STATE_UNSPECIFIED":   0,
		"AGENT_STATE_UNINITIALIZED": 1,
		"AGENT_STATE_INITIALIZING":  2,
		"AGENT_STATE_READY":         3,
		"AGENT_STATE_RUNNING":       4,
		"AGENT_STATE_STOPPING":      5,
		"AGENT_STATE_STOPPED":       6,
		"AGENT_STATE_ERROR":         7,
	}
)

Enum value maps for AgentState.

View Source 
var (
	HealthStatus_name = map[int32]string{
		0: "HEALTH_STATUS_UNKNOWN",
		1: "HEALTH_STATUS_SERVING",
		2: "HEALTH_STATUS_NOT_SERVING",
		3: "HEALTH_STATUS_SERVICE_UNKNOWN",
	}
	HealthStatus_value = map[string]int32{
		"HEALTH_STATUS_UNKNOWN":         0,
		"HEALTH_STATUS_SERVING":         1,
		"HEALTH_STATUS_NOT_SERVING":     2,
		"HEALTH_STATUS_SERVICE_UNKNOWN": 3,
	}
)

Enum value maps for HealthStatus.

View Source 
var (
	WorkerStatus_name = map[int32]string{
		0: "WORKER_STATUS_UNSPECIFIED",
		1: "WORKER_STATUS_STARTING",
		2: "WORKER_STATUS_READY",
		3: "WORKER_STATUS_BUSY",
		4: "WORKER_STATUS_OVERLOADED",
		5: "WORKER_STATUS_SHUTTING_DOWN",
		6: "WORKER_STATUS_UNAVAILABLE",
	}
	WorkerStatus_value = map[string]int32{
		"WORKER_STATUS_UNSPECIFIED":   0,
		"WORKER_STATUS_STARTING":      1,
		"WORKER_STATUS_READY":         2,
		"WORKER_STATUS_BUSY":          3,
		"WORKER_STATUS_OVERLOADED":    4,
		"WORKER_STATUS_SHUTTING_DOWN": 5,
		"WORKER_STATUS_UNAVAILABLE":   6,
	}
)

Enum value maps for WorkerStatus.

View Source 
var (
	PlacementStrategy_name = map[int32]string{
		0: "PLACEMENT_STRATEGY_UNSPECIFIED",
		1: "PLACEMENT_STRATEGY_ROUND_ROBIN",
		2: "PLACEMENT_STRATEGY_LEAST_LOADED",
		3: "PLACEMENT_STRATEGY_RESOURCE_AWARE",
		4: "PLACEMENT_STRATEGY_AFFINITY",
	}
	PlacementStrategy_value = map[string]int32{
		"PLACEMENT_STRATEGY_UNSPECIFIED":    0,
		"PLACEMENT_STRATEGY_ROUND_ROBIN":    1,
		"PLACEMENT_STRATEGY_LEAST_LOADED":   2,
		"PLACEMENT_STRATEGY_RESOURCE_AWARE": 3,
		"PLACEMENT_STRATEGY_AFFINITY":       4,
	}
)

Enum value maps for PlacementStrategy.

View Source 
var (
	ConversationState_name = map[int32]string{
		0: "CONVERSATION_STATE_UNSPECIFIED",
		1: "CONVERSATION_STATE_ACTIVE",
		2: "CONVERSATION_STATE_PAUSED",
		3: "CONVERSATION_STATE_ENDED",
		4: "CONVERSATION_STATE_ERROR",
	}
	ConversationState_value = map[string]int32{
		"CONVERSATION_STATE_UNSPECIFIED": 0,
		"CONVERSATION_STATE_ACTIVE":      1,
		"CONVERSATION_STATE_PAUSED":      2,
		"CONVERSATION_STATE_ENDED":       3,
		"CONVERSATION_STATE_ERROR":       4,
	}
)

Enum value maps for ConversationState.

View Source 
var (
	ConversationEventType_name = map[int32]string{
		0: "CONVERSATION_EVENT_TYPE_UNSPECIFIED",
		1: "CONVERSATION_EVENT_TYPE_MESSAGE_ADDED",
		2: "CONVERSATION_EVENT_TYPE_PARTICIPANT_JOINED",
		3: "CONVERSATION_EVENT_TYPE_PARTICIPANT_LEFT",
		4: "CONVERSATION_EVENT_TYPE_STATE_CHANGED",
	}
	ConversationEventType_value = map[string]int32{
		"CONVERSATION_EVENT_TYPE_UNSPECIFIED":        0,
		"CONVERSATION_EVENT_TYPE_MESSAGE_ADDED":      1,
		"CONVERSATION_EVENT_TYPE_PARTICIPANT_JOINED": 2,
		"CONVERSATION_EVENT_TYPE_PARTICIPANT_LEFT":   3,
		"CONVERSATION_EVENT_TYPE_STATE_CHANGED":      4,
	}
)

Enum value maps for ConversationEventType.

View Source 
var (
	RuntimeState_name = map[int32]string{
		0: "RUNTIME_STATE_UNSPECIFIED",
		1: "RUNTIME_STATE_STARTING",
		2: "RUNTIME_STATE_READY",
		3: "RUNTIME_STATE_DEGRADED",
		4: "RUNTIME_STATE_SHUTTING_DOWN",
		5: "RUNTIME_STATE_STOPPED",
	}
	RuntimeState_value = map[string]int32{
		"RUNTIME_STATE_UNSPECIFIED":   0,
		"RUNTIME_STATE_STARTING":      1,
		"RUNTIME_STATE_READY":         2,
		"RUNTIME_STATE_DEGRADED":      3,
		"RUNTIME_STATE_SHUTTING_DOWN": 4,
		"RUNTIME_STATE_STOPPED":       5,
	}
)

Enum value maps for RuntimeState.

View Source 
var AgentWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "goautogen.api.v1.AgentWorkerService",
	HandlerType: (*AgentWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterAgent",
			Handler:    _AgentWorkerService_RegisterAgent_Handler,
		},
		{
			MethodName: "UnregisterAgent",
			Handler:    _AgentWorkerService_UnregisterAgent_Handler,
		},
		{
			MethodName: "ExecuteMessage",
			Handler:    _AgentWorkerService_ExecuteMessage_Handler,
		},
		{
			MethodName: "GetAgentStatus",
			Handler:    _AgentWorkerService_GetAgentStatus_Handler,
		},
		{
			MethodName: "ListAgents",
			Handler:    _AgentWorkerService_ListAgents_Handler,
		},
		{
			MethodName: "SaveAgentState",
			Handler:    _AgentWorkerService_SaveAgentState_Handler,
		},
		{
			MethodName: "LoadAgentState",
			Handler:    _AgentWorkerService_LoadAgentState_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamMessages",
			Handler:       _AgentWorkerService_StreamMessages_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/proto/agent_worker.proto",
}

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

View Source 
var File_api_proto_agent_worker_proto protoreflect.FileDescriptor
View Source 
var File_api_proto_health_proto protoreflect.FileDescriptor
View Source 
var File_api_proto_runtime_proto protoreflect.FileDescriptor
View Source 
var HealthService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "goautogen.api.v1.HealthService",
	HandlerType: (*HealthServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Check",
			Handler:    _HealthService_Check_Handler,
		},
		{
			MethodName: "GetHealthStatus",
			Handler:    _HealthService_GetHealthStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _HealthService_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/proto/health.proto",
}

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

View Source 
var RuntimeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "goautogen.api.v1.RuntimeService",
	HandlerType: (*RuntimeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterWorker",
			Handler:    _RuntimeService_RegisterWorker_Handler,
		},
		{
			MethodName: "UnregisterWorker",
			Handler:    _RuntimeService_UnregisterWorker_Handler,
		},
		{
			MethodName: "GetWorkerInfo",
			Handler:    _RuntimeService_GetWorkerInfo_Handler,
		},
		{
			MethodName: "ListWorkers",
			Handler:    _RuntimeService_ListWorkers_Handler,
		},
		{
			MethodName: "PlaceAgent",
			Handler:    _RuntimeService_PlaceAgent_Handler,
		},
		{
			MethodName: "RouteMessage",
			Handler:    _RuntimeService_RouteMessage_Handler,
		},
		{
			MethodName: "StartConversation",
			Handler:    _RuntimeService_StartConversation_Handler,
		},
		{
			MethodName: "EndConversation",
			Handler:    _RuntimeService_EndConversation_Handler,
		},
		{
			MethodName: "GetConversation",
			Handler:    _RuntimeService_GetConversation_Handler,
		},
		{
			MethodName: "ListConversations",
			Handler:    _RuntimeService_ListConversations_Handler,
		},
		{
			MethodName: "GetRuntimeStatus",
			Handler:    _RuntimeService_GetRuntimeStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamConversationEvents",
			Handler:       _RuntimeService_StreamConversationEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/proto/runtime.proto",
}

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

Functions

func RegisterAgentWorkerServiceServer 

func RegisterAgentWorkerServiceServer(s grpc.ServiceRegistrar, srv AgentWorkerServiceServer)

func RegisterHealthServiceServer 

func RegisterHealthServiceServer(s grpc.ServiceRegistrar, srv HealthServiceServer)

func RegisterRuntimeServiceServer 

func RegisterRuntimeServiceServer(s grpc.ServiceRegistrar, srv RuntimeServiceServer)

Types

type AgentID 

type AgentID struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Key  string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

AgentID represents a unique agent identifier

func (*AgentID) Descriptor deprecated 

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

Deprecated: Use AgentID.ProtoReflect.Descriptor instead.

func (*AgentID) GetKey 

func (x *AgentID) GetKey() string

func (*AgentID) GetType 

func (x *AgentID) GetType() string

func (*AgentID) ProtoMessage 

func (*AgentID) ProtoMessage()

func (*AgentID) ProtoReflect 

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

func (*AgentID) Reset 

func (x *AgentID) Reset()

func (*AgentID) String 

func (x *AgentID) String() string

type AgentInfo 

type AgentInfo struct {
	AgentId  *AgentID       `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Metadata *AgentMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Status   *AgentStatus   `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentInfo) Descriptor deprecated 

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

Deprecated: Use AgentInfo.ProtoReflect.Descriptor instead.

func (*AgentInfo) GetAgentId 

func (x *AgentInfo) GetAgentId() *AgentID

func (*AgentInfo) GetMetadata 

func (x *AgentInfo) GetMetadata() *AgentMetadata

func (*AgentInfo) GetStatus 

func (x *AgentInfo) GetStatus() *AgentStatus

func (*AgentInfo) ProtoMessage 

func (*AgentInfo) ProtoMessage()

func (*AgentInfo) ProtoReflect 

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

func (*AgentInfo) Reset 

func (x *AgentInfo) Reset()

func (*AgentInfo) String 

func (x *AgentInfo) String() string

type AgentMetadata 

type AgentMetadata struct {
	Name        string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string               `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Version     string               `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Tags        []string             `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	Config      map[string]string    `` /* 139-byte string literal not displayed */
	CreatedAt   *timestamp.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   *timestamp.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

AgentMetadata contains descriptive information about an agent

func (*AgentMetadata) Descriptor deprecated 

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

Deprecated: Use AgentMetadata.ProtoReflect.Descriptor instead.

func (*AgentMetadata) GetConfig 

func (x *AgentMetadata) GetConfig() map[string]string

func (*AgentMetadata) GetCreatedAt 

func (x *AgentMetadata) GetCreatedAt() *timestamp.Timestamp

func (*AgentMetadata) GetDescription 

func (x *AgentMetadata) GetDescription() string

func (*AgentMetadata) GetName 

func (x *AgentMetadata) GetName() string

func (*AgentMetadata) GetTags 

func (x *AgentMetadata) GetTags() []string

func (*AgentMetadata) GetUpdatedAt 

func (x *AgentMetadata) GetUpdatedAt() *timestamp.Timestamp

func (*AgentMetadata) GetVersion 

func (x *AgentMetadata) GetVersion() string

func (*AgentMetadata) ProtoMessage 

func (*AgentMetadata) ProtoMessage()

func (*AgentMetadata) ProtoReflect 

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

func (*AgentMetadata) Reset 

func (x *AgentMetadata) Reset()

func (*AgentMetadata) String 

func (x *AgentMetadata) String() string

type AgentState 

type AgentState int32

AgentState represents the operational state of an agent 

const (
	AgentState_AGENT_STATE_UNSPECIFIED   AgentState = 0
	AgentState_AGENT_STATE_UNINITIALIZED AgentState = 1
	AgentState_AGENT_STATE_INITIALIZING  AgentState = 2
	AgentState_AGENT_STATE_READY         AgentState = 3
	AgentState_AGENT_STATE_RUNNING       AgentState = 4
	AgentState_AGENT_STATE_STOPPING      AgentState = 5
	AgentState_AGENT_STATE_STOPPED       AgentState = 6
	AgentState_AGENT_STATE_ERROR         AgentState = 7
)

func (AgentState) Descriptor 

func (AgentState) Descriptor() protoreflect.EnumDescriptor

func (AgentState) Enum 

func (x AgentState) Enum() *AgentState

func (AgentState) EnumDescriptor deprecated 

func (AgentState) EnumDescriptor() ([]byte, []int)

Deprecated: Use AgentState.Descriptor instead.

func (AgentState) Number 

func (x AgentState) Number() protoreflect.EnumNumber

func (AgentState) String 

func (x AgentState) String() string

func (AgentState) Type 

func (AgentState) Type() protoreflect.EnumType

type AgentStatus 

type AgentStatus struct {
	State        AgentState           `protobuf:"varint,1,opt,name=state,proto3,enum=goautogen.api.v1.AgentState" json:"state,omitempty"`
	LastActive   *timestamp.Timestamp `protobuf:"bytes,2,opt,name=last_active,json=lastActive,proto3" json:"last_active,omitempty"`
	MessageCount int64                `protobuf:"varint,3,opt,name=message_count,json=messageCount,proto3" json:"message_count,omitempty"`
	ErrorCount   int64                `protobuf:"varint,4,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	Metrics      map[string]*any1.Any `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

AgentStatus represents the current status of an agent

func (*AgentStatus) Descriptor deprecated 

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

Deprecated: Use AgentStatus.ProtoReflect.Descriptor instead.

func (*AgentStatus) GetErrorCount 

func (x *AgentStatus) GetErrorCount() int64

func (*AgentStatus) GetLastActive 

func (x *AgentStatus) GetLastActive() *timestamp.Timestamp

func (*AgentStatus) GetMessageCount 

func (x *AgentStatus) GetMessageCount() int64

func (*AgentStatus) GetMetrics 

func (x *AgentStatus) GetMetrics() map[string]*any1.Any

func (*AgentStatus) GetState 

func (x *AgentStatus) GetState() AgentState

func (*AgentStatus) ProtoMessage 

func (*AgentStatus) ProtoMessage()

func (*AgentStatus) ProtoReflect 

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

func (*AgentStatus) Reset 

func (x *AgentStatus) Reset()

func (*AgentStatus) String 

func (x *AgentStatus) String() string

type AgentWorkerServiceClient 

type AgentWorkerServiceClient interface {
	// RegisterAgent registers a new agent on this worker
	RegisterAgent(ctx context.Context, in *RegisterAgentRequest, opts ...grpc.CallOption) (*RegisterAgentResponse, error)
	// UnregisterAgent removes an agent from this worker
	UnregisterAgent(ctx context.Context, in *UnregisterAgentRequest, opts ...grpc.CallOption) (*UnregisterAgentResponse, error)
	// ExecuteMessage executes a message on an agent
	ExecuteMessage(ctx context.Context, in *ExecuteMessageRequest, opts ...grpc.CallOption) (*ExecuteMessageResponse, error)
	// StreamMessages establishes a bidirectional stream for real-time message handling
	StreamMessages(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamMessageRequest, StreamMessageResponse], error)
	// GetAgentStatus returns the status of a specific agent
	GetAgentStatus(ctx context.Context, in *GetAgentStatusRequest, opts ...grpc.CallOption) (*GetAgentStatusResponse, error)
	// ListAgents returns all agents running on this worker
	ListAgents(ctx context.Context, in *ListAgentsRequest, opts ...grpc.CallOption) (*ListAgentsResponse, error)
	// SaveAgentState saves the current state of an agent
	SaveAgentState(ctx context.Context, in *SaveAgentStateRequest, opts ...grpc.CallOption) (*SaveAgentStateResponse, error)
	// LoadAgentState loads the state of an agent
	LoadAgentState(ctx context.Context, in *LoadAgentStateRequest, opts ...grpc.CallOption) (*LoadAgentStateResponse, error)
}

AgentWorkerServiceClient is the client API for AgentWorkerService 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.

AgentWorkerService defines the service for managing agents on worker processes

func NewAgentWorkerServiceClient 

func NewAgentWorkerServiceClient(cc grpc.ClientConnInterface) AgentWorkerServiceClient

type AgentWorkerServiceServer 

type AgentWorkerServiceServer interface {
	// RegisterAgent registers a new agent on this worker
	RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
	// UnregisterAgent removes an agent from this worker
	UnregisterAgent(context.Context, *UnregisterAgentRequest) (*UnregisterAgentResponse, error)
	// ExecuteMessage executes a message on an agent
	ExecuteMessage(context.Context, *ExecuteMessageRequest) (*ExecuteMessageResponse, error)
	// StreamMessages establishes a bidirectional stream for real-time message handling
	StreamMessages(grpc.BidiStreamingServer[StreamMessageRequest, StreamMessageResponse]) error
	// GetAgentStatus returns the status of a specific agent
	GetAgentStatus(context.Context, *GetAgentStatusRequest) (*GetAgentStatusResponse, error)
	// ListAgents returns all agents running on this worker
	ListAgents(context.Context, *ListAgentsRequest) (*ListAgentsResponse, error)
	// SaveAgentState saves the current state of an agent
	SaveAgentState(context.Context, *SaveAgentStateRequest) (*SaveAgentStateResponse, error)
	// LoadAgentState loads the state of an agent
	LoadAgentState(context.Context, *LoadAgentStateRequest) (*LoadAgentStateResponse, error)
	// contains filtered or unexported methods
}

AgentWorkerServiceServer is the server API for AgentWorkerService service. All implementations must embed UnimplementedAgentWorkerServiceServer for forward compatibility.

AgentWorkerService defines the service for managing agents on worker processes

type AgentWorkerService_StreamMessagesClient 

type AgentWorkerService_StreamMessagesClient = grpc.BidiStreamingClient[StreamMessageRequest, StreamMessageResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type AgentWorkerService_StreamMessagesServer 

type AgentWorkerService_StreamMessagesServer = grpc.BidiStreamingServer[StreamMessageRequest, StreamMessageResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Conversation 

type Conversation struct {
	ConversationId *ConversationID      `protobuf:"bytes,1,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
	Participants   []*AgentID           `protobuf:"bytes,2,rep,name=participants,proto3" json:"participants,omitempty"`
	State          ConversationState    `protobuf:"varint,3,opt,name=state,proto3,enum=goautogen.api.v1.ConversationState" json:"state,omitempty"`
	StartedAt      *timestamp.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	LastActivity   *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_activity,json=lastActivity,proto3" json:"last_activity,omitempty"`
	Metadata       map[string]*any1.Any `` /* 143-byte string literal not displayed */
	History        []*Message           `protobuf:"bytes,7,rep,name=history,proto3" json:"history,omitempty"`
	// contains filtered or unexported fields
}

Conversation represents a conversation between agents

func (*Conversation) Descriptor deprecated 

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

Deprecated: Use Conversation.ProtoReflect.Descriptor instead.

func (*Conversation) GetConversationId 

func (x *Conversation) GetConversationId() *ConversationID

func (*Conversation) GetHistory 

func (x *Conversation) GetHistory() []*Message

func (*Conversation) GetLastActivity 

func (x *Conversation) GetLastActivity() *timestamp.Timestamp

func (*Conversation) GetMetadata 

func (x *Conversation) GetMetadata() map[string]*any1.Any

func (*Conversation) GetParticipants 

func (x *Conversation) GetParticipants() []*AgentID

func (*Conversation) GetStartedAt 

func (x *Conversation) GetStartedAt() *timestamp.Timestamp

func (*Conversation) GetState 

func (x *Conversation) GetState() ConversationState

func (*Conversation) ProtoMessage 

func (*Conversation) ProtoMessage()

func (*Conversation) ProtoReflect 

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

func (*Conversation) Reset 

func (x *Conversation) Reset()

func (*Conversation) String 

func (x *Conversation) String() string

type ConversationEvent 

type ConversationEvent struct {
	EventId        string                `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	EventType      ConversationEventType `` /* 133-byte string literal not displayed */
	ConversationId *ConversationID       `protobuf:"bytes,3,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
	Message        *Message              `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	Participant    *AgentID              `protobuf:"bytes,5,opt,name=participant,proto3" json:"participant,omitempty"`
	Timestamp      *timestamp.Timestamp  `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Metadata       map[string]*any1.Any  `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

ConversationEvent represents events in conversations

func (*ConversationEvent) Descriptor deprecated 

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

Deprecated: Use ConversationEvent.ProtoReflect.Descriptor instead.

func (*ConversationEvent) GetConversationId 

func (x *ConversationEvent) GetConversationId() *ConversationID

func (*ConversationEvent) GetEventId 

func (x *ConversationEvent) GetEventId() string

func (*ConversationEvent) GetEventType 

func (x *ConversationEvent) GetEventType() ConversationEventType

func (*ConversationEvent) GetMessage 

func (x *ConversationEvent) GetMessage() *Message

func (*ConversationEvent) GetMetadata 

func (x *ConversationEvent) GetMetadata() map[string]*any1.Any

func (*ConversationEvent) GetParticipant 

func (x *ConversationEvent) GetParticipant() *AgentID

func (*ConversationEvent) GetTimestamp 

func (x *ConversationEvent) GetTimestamp() *timestamp.Timestamp

func (*ConversationEvent) ProtoMessage 

func (*ConversationEvent) ProtoMessage()

func (*ConversationEvent) ProtoReflect 

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

func (*ConversationEvent) Reset 

func (x *ConversationEvent) Reset()

func (*ConversationEvent) String 

func (x *ConversationEvent) String() string

type ConversationEventType 

type ConversationEventType int32
const (
	ConversationEventType_CONVERSATION_EVENT_TYPE_UNSPECIFIED        ConversationEventType = 0
	ConversationEventType_CONVERSATION_EVENT_TYPE_MESSAGE_ADDED      ConversationEventType = 1
	ConversationEventType_CONVERSATION_EVENT_TYPE_PARTICIPANT_JOINED ConversationEventType = 2
	ConversationEventType_CONVERSATION_EVENT_TYPE_PARTICIPANT_LEFT   ConversationEventType = 3
	ConversationEventType_CONVERSATION_EVENT_TYPE_STATE_CHANGED      ConversationEventType = 4
)

func (ConversationEventType) Descriptor 

func (ConversationEventType) Descriptor() protoreflect.EnumDescriptor

func (ConversationEventType) Enum 

func (x ConversationEventType) Enum() *ConversationEventType

func (ConversationEventType) EnumDescriptor deprecated 

func (ConversationEventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConversationEventType.Descriptor instead.

func (ConversationEventType) Number 

func (x ConversationEventType) Number() protoreflect.EnumNumber

func (ConversationEventType) String 

func (x ConversationEventType) String() string

func (ConversationEventType) Type 

func (ConversationEventType) Type() protoreflect.EnumType

type ConversationID 

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

ConversationID uniquely identifies a conversation

func (*ConversationID) Descriptor deprecated 

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

Deprecated: Use ConversationID.ProtoReflect.Descriptor instead.

func (*ConversationID) GetId 

func (x *ConversationID) GetId() string

func (*ConversationID) ProtoMessage 

func (*ConversationID) ProtoMessage()

func (*ConversationID) ProtoReflect 

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

func (*ConversationID) Reset 

func (x *ConversationID) Reset()

func (*ConversationID) String 

func (x *ConversationID) String() string

type ConversationState 

type ConversationState int32
const (
	ConversationState_CONVERSATION_STATE_UNSPECIFIED ConversationState = 0
	ConversationState_CONVERSATION_STATE_ACTIVE      ConversationState = 1
	ConversationState_CONVERSATION_STATE_PAUSED      ConversationState = 2
	ConversationState_CONVERSATION_STATE_ENDED       ConversationState = 3
	ConversationState_CONVERSATION_STATE_ERROR       ConversationState = 4
)

func (ConversationState) Descriptor 

func (ConversationState) Descriptor() protoreflect.EnumDescriptor

func (ConversationState) Enum 

func (x ConversationState) Enum() *ConversationState

func (ConversationState) EnumDescriptor deprecated 

func (ConversationState) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConversationState.Descriptor instead.

func (ConversationState) Number 

func (x ConversationState) Number() protoreflect.EnumNumber

func (ConversationState) String 

func (x ConversationState) String() string

func (ConversationState) Type 

func (ConversationState) Type() protoreflect.EnumType

type EndConversationRequest 

type EndConversationRequest struct {
	ConversationId *ConversationID `protobuf:"bytes,1,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
	Reason         string          `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

EndConversationRequest ends a conversation

func (*EndConversationRequest) Descriptor deprecated 

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

Deprecated: Use EndConversationRequest.ProtoReflect.Descriptor instead.

func (*EndConversationRequest) GetConversationId 

func (x *EndConversationRequest) GetConversationId() *ConversationID

func (*EndConversationRequest) GetReason 

func (x *EndConversationRequest) GetReason() string

func (*EndConversationRequest) ProtoMessage 

func (*EndConversationRequest) ProtoMessage()

func (*EndConversationRequest) ProtoReflect 

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

func (*EndConversationRequest) Reset 

func (x *EndConversationRequest) Reset()

func (*EndConversationRequest) String 

func (x *EndConversationRequest) String() string

type EndConversationResponse 

type EndConversationResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*EndConversationResponse) Descriptor deprecated 

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

Deprecated: Use EndConversationResponse.ProtoReflect.Descriptor instead.

func (*EndConversationResponse) GetErrorMessage 

func (x *EndConversationResponse) GetErrorMessage() string

func (*EndConversationResponse) GetSuccess 

func (x *EndConversationResponse) GetSuccess() bool

func (*EndConversationResponse) ProtoMessage 

func (*EndConversationResponse) ProtoMessage()

func (*EndConversationResponse) ProtoReflect 

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

func (*EndConversationResponse) Reset 

func (x *EndConversationResponse) Reset()

func (*EndConversationResponse) String 

func (x *EndConversationResponse) String() string

type ExecuteMessageRequest 

type ExecuteMessageRequest struct {
	AgentId   *AgentID        `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Message   *Message        `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Context   *MessageContext `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	TimeoutMs int64           `protobuf:"varint,4,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"`
	// contains filtered or unexported fields
}

ExecuteMessageRequest executes a message on an agent

func (*ExecuteMessageRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteMessageRequest.ProtoReflect.Descriptor instead.

func (*ExecuteMessageRequest) GetAgentId 

func (x *ExecuteMessageRequest) GetAgentId() *AgentID

func (*ExecuteMessageRequest) GetContext 

func (x *ExecuteMessageRequest) GetContext() *MessageContext

func (*ExecuteMessageRequest) GetMessage 

func (x *ExecuteMessageRequest) GetMessage() *Message

func (*ExecuteMessageRequest) GetTimeoutMs 

func (x *ExecuteMessageRequest) GetTimeoutMs() int64

func (*ExecuteMessageRequest) ProtoMessage 

func (*ExecuteMessageRequest) ProtoMessage()

func (*ExecuteMessageRequest) ProtoReflect 

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

func (*ExecuteMessageRequest) Reset 

func (x *ExecuteMessageRequest) Reset()

func (*ExecuteMessageRequest) String 

func (x *ExecuteMessageRequest) String() string

type ExecuteMessageResponse 

type ExecuteMessageResponse struct {
	Success         bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage    string   `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ResponseMessage *Message `protobuf:"bytes,3,opt,name=response_message,json=responseMessage,proto3" json:"response_message,omitempty"`
	ExecutionTimeMs int64    `protobuf:"varint,4,opt,name=execution_time_ms,json=executionTimeMs,proto3" json:"execution_time_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteMessageResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteMessageResponse.ProtoReflect.Descriptor instead.

func (*ExecuteMessageResponse) GetErrorMessage 

func (x *ExecuteMessageResponse) GetErrorMessage() string

func (*ExecuteMessageResponse) GetExecutionTimeMs 

func (x *ExecuteMessageResponse) GetExecutionTimeMs() int64

func (*ExecuteMessageResponse) GetResponseMessage 

func (x *ExecuteMessageResponse) GetResponseMessage() *Message

func (*ExecuteMessageResponse) GetSuccess 

func (x *ExecuteMessageResponse) GetSuccess() bool

func (*ExecuteMessageResponse) ProtoMessage 

func (*ExecuteMessageResponse) ProtoMessage()

func (*ExecuteMessageResponse) ProtoReflect 

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

func (*ExecuteMessageResponse) Reset 

func (x *ExecuteMessageResponse) Reset()

func (*ExecuteMessageResponse) String 

func (x *ExecuteMessageResponse) String() string

type GetAgentStatusRequest 

type GetAgentStatusRequest struct {
	AgentId *AgentID `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

GetAgentStatusRequest returns the status of a specific agent

func (*GetAgentStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetAgentStatusRequest.ProtoReflect.Descriptor instead.

func (*GetAgentStatusRequest) GetAgentId 

func (x *GetAgentStatusRequest) GetAgentId() *AgentID

func (*GetAgentStatusRequest) ProtoMessage 

func (*GetAgentStatusRequest) ProtoMessage()

func (*GetAgentStatusRequest) ProtoReflect 

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

func (*GetAgentStatusRequest) Reset 

func (x *GetAgentStatusRequest) Reset()

func (*GetAgentStatusRequest) String 

func (x *GetAgentStatusRequest) String() string

type GetAgentStatusResponse 

type GetAgentStatusResponse struct {
	Success      bool         `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string       `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Status       *AgentStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAgentStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetAgentStatusResponse.ProtoReflect.Descriptor instead.

func (*GetAgentStatusResponse) GetErrorMessage 

func (x *GetAgentStatusResponse) GetErrorMessage() string

func (*GetAgentStatusResponse) GetStatus 

func (x *GetAgentStatusResponse) GetStatus() *AgentStatus

func (*GetAgentStatusResponse) GetSuccess 

func (x *GetAgentStatusResponse) GetSuccess() bool

func (*GetAgentStatusResponse) ProtoMessage 

func (*GetAgentStatusResponse) ProtoMessage()

func (*GetAgentStatusResponse) ProtoReflect 

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

func (*GetAgentStatusResponse) Reset 

func (x *GetAgentStatusResponse) Reset()

func (*GetAgentStatusResponse) String 

func (x *GetAgentStatusResponse) String() string

type GetConversationRequest 

type GetConversationRequest struct {
	ConversationId *ConversationID `protobuf:"bytes,1,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
	IncludeHistory bool            `protobuf:"varint,2,opt,name=include_history,json=includeHistory,proto3" json:"include_history,omitempty"`
	HistoryLimit   int32           `protobuf:"varint,3,opt,name=history_limit,json=historyLimit,proto3" json:"history_limit,omitempty"`
	// contains filtered or unexported fields
}

GetConversationRequest returns conversation details

func (*GetConversationRequest) Descriptor deprecated 

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

Deprecated: Use GetConversationRequest.ProtoReflect.Descriptor instead.

func (*GetConversationRequest) GetConversationId 

func (x *GetConversationRequest) GetConversationId() *ConversationID

func (*GetConversationRequest) GetHistoryLimit 

func (x *GetConversationRequest) GetHistoryLimit() int32

func (*GetConversationRequest) GetIncludeHistory 

func (x *GetConversationRequest) GetIncludeHistory() bool

func (*GetConversationRequest) ProtoMessage 

func (*GetConversationRequest) ProtoMessage()

func (*GetConversationRequest) ProtoReflect 

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

func (*GetConversationRequest) Reset 

func (x *GetConversationRequest) Reset()

func (*GetConversationRequest) String 

func (x *GetConversationRequest) String() string

type GetConversationResponse 

type GetConversationResponse struct {
	Success      bool          `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string        `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Conversation *Conversation `protobuf:"bytes,3,opt,name=conversation,proto3" json:"conversation,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConversationResponse) Descriptor deprecated 

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

Deprecated: Use GetConversationResponse.ProtoReflect.Descriptor instead.

func (*GetConversationResponse) GetConversation 

func (x *GetConversationResponse) GetConversation() *Conversation

func (*GetConversationResponse) GetErrorMessage 

func (x *GetConversationResponse) GetErrorMessage() string

func (*GetConversationResponse) GetSuccess 

func (x *GetConversationResponse) GetSuccess() bool

func (*GetConversationResponse) ProtoMessage 

func (*GetConversationResponse) ProtoMessage()

func (*GetConversationResponse) ProtoReflect 

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

func (*GetConversationResponse) Reset 

func (x *GetConversationResponse) Reset()

func (*GetConversationResponse) String 

func (x *GetConversationResponse) String() string

type GetHealthStatusRequest 

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

GetHealthStatusRequest for detailed health information

func (*GetHealthStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetHealthStatusRequest.ProtoReflect.Descriptor instead.

func (*GetHealthStatusRequest) GetService 

func (x *GetHealthStatusRequest) GetService() string

func (*GetHealthStatusRequest) ProtoMessage 

func (*GetHealthStatusRequest) ProtoMessage()

func (*GetHealthStatusRequest) ProtoReflect 

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

func (*GetHealthStatusRequest) Reset 

func (x *GetHealthStatusRequest) Reset()

func (*GetHealthStatusRequest) String 

func (x *GetHealthStatusRequest) String() string

type GetHealthStatusResponse 

type GetHealthStatusResponse struct {
	Status    HealthStatus         `protobuf:"varint,1,opt,name=status,proto3,enum=goautogen.api.v1.HealthStatus" json:"status,omitempty"`
	Message   string               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Details   *HealthDetails       `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHealthStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetHealthStatusResponse.ProtoReflect.Descriptor instead.

func (*GetHealthStatusResponse) GetDetails 

func (x *GetHealthStatusResponse) GetDetails() *HealthDetails

func (*GetHealthStatusResponse) GetMessage 

func (x *GetHealthStatusResponse) GetMessage() string

func (*GetHealthStatusResponse) GetStatus 

func (x *GetHealthStatusResponse) GetStatus() HealthStatus

func (*GetHealthStatusResponse) GetTimestamp 

func (x *GetHealthStatusResponse) GetTimestamp() *timestamp.Timestamp

func (*GetHealthStatusResponse) ProtoMessage 

func (*GetHealthStatusResponse) ProtoMessage()

func (*GetHealthStatusResponse) ProtoReflect 

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

func (*GetHealthStatusResponse) Reset 

func (x *GetHealthStatusResponse) Reset()

func (*GetHealthStatusResponse) String 

func (x *GetHealthStatusResponse) String() string

type GetRuntimeStatusRequest 

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

GetRuntimeStatusRequest returns runtime status

func (*GetRuntimeStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetRuntimeStatusRequest.ProtoReflect.Descriptor instead.

func (*GetRuntimeStatusRequest) ProtoMessage 

func (*GetRuntimeStatusRequest) ProtoMessage()

func (*GetRuntimeStatusRequest) ProtoReflect 

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

func (*GetRuntimeStatusRequest) Reset 

func (x *GetRuntimeStatusRequest) Reset()

func (*GetRuntimeStatusRequest) String 

func (x *GetRuntimeStatusRequest) String() string

type GetRuntimeStatusResponse 

type GetRuntimeStatusResponse struct {
	Success      bool           `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string         `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Status       *RuntimeStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRuntimeStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetRuntimeStatusResponse.ProtoReflect.Descriptor instead.

func (*GetRuntimeStatusResponse) GetErrorMessage 

func (x *GetRuntimeStatusResponse) GetErrorMessage() string

func (*GetRuntimeStatusResponse) GetStatus 

func (x *GetRuntimeStatusResponse) GetStatus() *RuntimeStatus

func (*GetRuntimeStatusResponse) GetSuccess 

func (x *GetRuntimeStatusResponse) GetSuccess() bool

func (*GetRuntimeStatusResponse) ProtoMessage 

func (*GetRuntimeStatusResponse) ProtoMessage()

func (*GetRuntimeStatusResponse) ProtoReflect 

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

func (*GetRuntimeStatusResponse) Reset 

func (x *GetRuntimeStatusResponse) Reset()

func (*GetRuntimeStatusResponse) String 

func (x *GetRuntimeStatusResponse) String() string

type GetWorkerInfoRequest 

type GetWorkerInfoRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

GetWorkerInfoRequest returns information about a worker

func (*GetWorkerInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkerInfoRequest.ProtoReflect.Descriptor instead.

func (*GetWorkerInfoRequest) GetWorkerId 

func (x *GetWorkerInfoRequest) GetWorkerId() string

func (*GetWorkerInfoRequest) ProtoMessage 

func (*GetWorkerInfoRequest) ProtoMessage()

func (*GetWorkerInfoRequest) ProtoReflect 

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

func (*GetWorkerInfoRequest) Reset 

func (x *GetWorkerInfoRequest) Reset()

func (*GetWorkerInfoRequest) String 

func (x *GetWorkerInfoRequest) String() string

type GetWorkerInfoResponse 

type GetWorkerInfoResponse struct {
	Success      bool        `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string      `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	WorkerInfo   *WorkerInfo `protobuf:"bytes,3,opt,name=worker_info,json=workerInfo,proto3" json:"worker_info,omitempty"`
	CurrentLoad  *WorkerLoad `protobuf:"bytes,4,opt,name=current_load,json=currentLoad,proto3" json:"current_load,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkerInfoResponse.ProtoReflect.Descriptor instead.

func (*GetWorkerInfoResponse) GetCurrentLoad 

func (x *GetWorkerInfoResponse) GetCurrentLoad() *WorkerLoad

func (*GetWorkerInfoResponse) GetErrorMessage 

func (x *GetWorkerInfoResponse) GetErrorMessage() string

func (*GetWorkerInfoResponse) GetSuccess 

func (x *GetWorkerInfoResponse) GetSuccess() bool

func (*GetWorkerInfoResponse) GetWorkerInfo 

func (x *GetWorkerInfoResponse) GetWorkerInfo() *WorkerInfo

func (*GetWorkerInfoResponse) ProtoMessage 

func (*GetWorkerInfoResponse) ProtoMessage()

func (*GetWorkerInfoResponse) ProtoReflect 

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

func (*GetWorkerInfoResponse) Reset 

func (x *GetWorkerInfoResponse) Reset()

func (*GetWorkerInfoResponse) String 

func (x *GetWorkerInfoResponse) String() string

type HealthCheck 

type HealthCheck struct {
	Name         string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status       HealthStatus         `protobuf:"varint,2,opt,name=status,proto3,enum=goautogen.api.v1.HealthStatus" json:"status,omitempty"`
	Message      string               `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	LastSuccess  *timestamp.Timestamp `protobuf:"bytes,4,opt,name=last_success,json=lastSuccess,proto3" json:"last_success,omitempty"`
	LastFailure  *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
	SuccessCount int64                `protobuf:"varint,6,opt,name=success_count,json=successCount,proto3" json:"success_count,omitempty"`
	FailureCount int64                `protobuf:"varint,7,opt,name=failure_count,json=failureCount,proto3" json:"failure_count,omitempty"`
	// contains filtered or unexported fields
}

HealthCheck represents an individual health check

func (*HealthCheck) Descriptor deprecated 

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

Deprecated: Use HealthCheck.ProtoReflect.Descriptor instead.

func (*HealthCheck) GetFailureCount 

func (x *HealthCheck) GetFailureCount() int64

func (*HealthCheck) GetLastFailure 

func (x *HealthCheck) GetLastFailure() *timestamp.Timestamp

func (*HealthCheck) GetLastSuccess 

func (x *HealthCheck) GetLastSuccess() *timestamp.Timestamp

func (*HealthCheck) GetMessage 

func (x *HealthCheck) GetMessage() string

func (*HealthCheck) GetName 

func (x *HealthCheck) GetName() string

func (*HealthCheck) GetStatus 

func (x *HealthCheck) GetStatus() HealthStatus

func (*HealthCheck) GetSuccessCount 

func (x *HealthCheck) GetSuccessCount() int64

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) ProtoReflect 

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

func (*HealthCheck) Reset 

func (x *HealthCheck) Reset()

func (*HealthCheck) String 

func (x *HealthCheck) String() string

type HealthCheckRequest 

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

HealthCheckRequest for health check operations

func (*HealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetService 

func (x *HealthCheckRequest) GetService() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status    HealthStatus         `protobuf:"varint,1,opt,name=status,proto3,enum=goautogen.api.v1.HealthStatus" json:"status,omitempty"`
	Message   string               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetMessage 

func (x *HealthCheckResponse) GetMessage() string

func (*HealthCheckResponse) GetStatus 

func (x *HealthCheckResponse) GetStatus() HealthStatus

func (*HealthCheckResponse) GetTimestamp 

func (x *HealthCheckResponse) GetTimestamp() *timestamp.Timestamp

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type HealthDetails 

type HealthDetails struct {
	CpuUsage          float64              `protobuf:"fixed64,1,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`
	MemoryUsage       float64              `protobuf:"fixed64,2,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`
	ActiveConnections int64                `protobuf:"varint,3,opt,name=active_connections,json=activeConnections,proto3" json:"active_connections,omitempty"`
	RequestsPerSecond int64                `protobuf:"varint,4,opt,name=requests_per_second,json=requestsPerSecond,proto3" json:"requests_per_second,omitempty"`
	ErrorsPerSecond   int64                `protobuf:"varint,5,opt,name=errors_per_second,json=errorsPerSecond,proto3" json:"errors_per_second,omitempty"`
	LastCheck         *timestamp.Timestamp `protobuf:"bytes,6,opt,name=last_check,json=lastCheck,proto3" json:"last_check,omitempty"`
	Checks            []*HealthCheck       `protobuf:"bytes,7,rep,name=checks,proto3" json:"checks,omitempty"`
	// contains filtered or unexported fields
}

HealthDetails provides detailed health information

func (*HealthDetails) Descriptor deprecated 

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

Deprecated: Use HealthDetails.ProtoReflect.Descriptor instead.

func (*HealthDetails) GetActiveConnections 

func (x *HealthDetails) GetActiveConnections() int64

func (*HealthDetails) GetChecks 

func (x *HealthDetails) GetChecks() []*HealthCheck

func (*HealthDetails) GetCpuUsage 

func (x *HealthDetails) GetCpuUsage() float64

func (*HealthDetails) GetErrorsPerSecond 

func (x *HealthDetails) GetErrorsPerSecond() int64

func (*HealthDetails) GetLastCheck 

func (x *HealthDetails) GetLastCheck() *timestamp.Timestamp

func (*HealthDetails) GetMemoryUsage 

func (x *HealthDetails) GetMemoryUsage() float64

func (*HealthDetails) GetRequestsPerSecond 

func (x *HealthDetails) GetRequestsPerSecond() int64

func (*HealthDetails) ProtoMessage 

func (*HealthDetails) ProtoMessage()

func (*HealthDetails) ProtoReflect 

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

func (*HealthDetails) Reset 

func (x *HealthDetails) Reset()

func (*HealthDetails) String 

func (x *HealthDetails) String() string

type HealthServiceClient 

type HealthServiceClient interface {
	// Check performs a health check
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// Watch performs a streaming health check
	Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[HealthCheckResponse], error)
	// GetHealthStatus returns detailed health information
	GetHealthStatus(ctx context.Context, in *GetHealthStatusRequest, opts ...grpc.CallOption) (*GetHealthStatusResponse, error)
}

HealthServiceClient is the client API for HealthService 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.

HealthService provides health checking functionality for workers and the runtime

func NewHealthServiceClient 

func NewHealthServiceClient(cc grpc.ClientConnInterface) HealthServiceClient

type HealthServiceServer 

type HealthServiceServer interface {
	// Check performs a health check
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// Watch performs a streaming health check
	Watch(*HealthCheckRequest, grpc.ServerStreamingServer[HealthCheckResponse]) error
	// GetHealthStatus returns detailed health information
	GetHealthStatus(context.Context, *GetHealthStatusRequest) (*GetHealthStatusResponse, error)
	// contains filtered or unexported methods
}

HealthServiceServer is the server API for HealthService service. All implementations must embed UnimplementedHealthServiceServer for forward compatibility.

HealthService provides health checking functionality for workers and the runtime

type HealthService_WatchClient 

type HealthService_WatchClient = grpc.ServerStreamingClient[HealthCheckResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type HealthService_WatchServer 

type HealthService_WatchServer = grpc.ServerStreamingServer[HealthCheckResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type HealthStatus 

type HealthStatus int32
const (
	HealthStatus_HEALTH_STATUS_UNKNOWN         HealthStatus = 0
	HealthStatus_HEALTH_STATUS_SERVING         HealthStatus = 1
	HealthStatus_HEALTH_STATUS_NOT_SERVING     HealthStatus = 2
	HealthStatus_HEALTH_STATUS_SERVICE_UNKNOWN HealthStatus = 3
)

func (HealthStatus) Descriptor 

func (HealthStatus) Descriptor() protoreflect.EnumDescriptor

func (HealthStatus) Enum 

func (x HealthStatus) Enum() *HealthStatus

func (HealthStatus) EnumDescriptor deprecated 

func (HealthStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use HealthStatus.Descriptor instead.

func (HealthStatus) Number 

func (x HealthStatus) Number() protoreflect.EnumNumber

func (HealthStatus) String 

func (x HealthStatus) String() string

func (HealthStatus) Type 

func (HealthStatus) Type() protoreflect.EnumType

type ListAgentsRequest 

type ListAgentsRequest struct {
	Filter    string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Limit     int32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

ListAgentsRequest returns all agents on the worker

func (*ListAgentsRequest) Descriptor deprecated 

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

Deprecated: Use ListAgentsRequest.ProtoReflect.Descriptor instead.

func (*ListAgentsRequest) GetFilter 

func (x *ListAgentsRequest) GetFilter() string

func (*ListAgentsRequest) GetLimit 

func (x *ListAgentsRequest) GetLimit() int32

func (*ListAgentsRequest) GetPageToken 

func (x *ListAgentsRequest) GetPageToken() string

func (*ListAgentsRequest) ProtoMessage 

func (*ListAgentsRequest) ProtoMessage()

func (*ListAgentsRequest) ProtoReflect 

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

func (*ListAgentsRequest) Reset 

func (x *ListAgentsRequest) Reset()

func (*ListAgentsRequest) String 

func (x *ListAgentsRequest) String() string

type ListAgentsResponse 

type ListAgentsResponse struct {
	Agents        []*AgentInfo `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	NextPageToken string       `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	TotalCount    int32        `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentsResponse) Descriptor deprecated 

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

Deprecated: Use ListAgentsResponse.ProtoReflect.Descriptor instead.

func (*ListAgentsResponse) GetAgents 

func (x *ListAgentsResponse) GetAgents() []*AgentInfo

func (*ListAgentsResponse) GetNextPageToken 

func (x *ListAgentsResponse) GetNextPageToken() string

func (*ListAgentsResponse) GetTotalCount 

func (x *ListAgentsResponse) GetTotalCount() int32

func (*ListAgentsResponse) ProtoMessage 

func (*ListAgentsResponse) ProtoMessage()

func (*ListAgentsResponse) ProtoReflect 

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

func (*ListAgentsResponse) Reset 

func (x *ListAgentsResponse) Reset()

func (*ListAgentsResponse) String 

func (x *ListAgentsResponse) String() string

type ListConversationsRequest 

type ListConversationsRequest struct {
	Filter      string            `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Limit       int32             `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	PageToken   string            `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	StateFilter ConversationState `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

ListConversationsRequest returns all conversations

func (*ListConversationsRequest) Descriptor deprecated 

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

Deprecated: Use ListConversationsRequest.ProtoReflect.Descriptor instead.

func (*ListConversationsRequest) GetFilter 

func (x *ListConversationsRequest) GetFilter() string

func (*ListConversationsRequest) GetLimit 

func (x *ListConversationsRequest) GetLimit() int32

func (*ListConversationsRequest) GetPageToken 

func (x *ListConversationsRequest) GetPageToken() string

func (*ListConversationsRequest) GetStateFilter 

func (x *ListConversationsRequest) GetStateFilter() ConversationState

func (*ListConversationsRequest) ProtoMessage 

func (*ListConversationsRequest) ProtoMessage()

func (*ListConversationsRequest) ProtoReflect 

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

func (*ListConversationsRequest) Reset 

func (x *ListConversationsRequest) Reset()

func (*ListConversationsRequest) String 

func (x *ListConversationsRequest) String() string

type ListConversationsResponse 

type ListConversationsResponse struct {
	Conversations []*Conversation `protobuf:"bytes,1,rep,name=conversations,proto3" json:"conversations,omitempty"`
	NextPageToken string          `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	TotalCount    int32           `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConversationsResponse) Descriptor deprecated 

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

Deprecated: Use ListConversationsResponse.ProtoReflect.Descriptor instead.

func (*ListConversationsResponse) GetConversations 

func (x *ListConversationsResponse) GetConversations() []*Conversation

func (*ListConversationsResponse) GetNextPageToken 

func (x *ListConversationsResponse) GetNextPageToken() string

func (*ListConversationsResponse) GetTotalCount 

func (x *ListConversationsResponse) GetTotalCount() int32

func (*ListConversationsResponse) ProtoMessage 

func (*ListConversationsResponse) ProtoMessage()

func (*ListConversationsResponse) ProtoReflect 

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

func (*ListConversationsResponse) Reset 

func (x *ListConversationsResponse) Reset()

func (*ListConversationsResponse) String 

func (x *ListConversationsResponse) String() string

type ListWorkersRequest 

type ListWorkersRequest struct {
	Filter    string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Limit     int32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

ListWorkersRequest returns all workers

func (*ListWorkersRequest) Descriptor deprecated 

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

Deprecated: Use ListWorkersRequest.ProtoReflect.Descriptor instead.

func (*ListWorkersRequest) GetFilter 

func (x *ListWorkersRequest) GetFilter() string

func (*ListWorkersRequest) GetLimit 

func (x *ListWorkersRequest) GetLimit() int32

func (*ListWorkersRequest) GetPageToken 

func (x *ListWorkersRequest) GetPageToken() string

func (*ListWorkersRequest) ProtoMessage 

func (*ListWorkersRequest) ProtoMessage()

func (*ListWorkersRequest) ProtoReflect 

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

func (*ListWorkersRequest) Reset 

func (x *ListWorkersRequest) Reset()

func (*ListWorkersRequest) String 

func (x *ListWorkersRequest) String() string

type ListWorkersResponse 

type ListWorkersResponse struct {
	Workers       []*WorkerInfo `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	NextPageToken string        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	TotalCount    int32         `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkersResponse) Descriptor deprecated 

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

Deprecated: Use ListWorkersResponse.ProtoReflect.Descriptor instead.

func (*ListWorkersResponse) GetNextPageToken 

func (x *ListWorkersResponse) GetNextPageToken() string

func (*ListWorkersResponse) GetTotalCount 

func (x *ListWorkersResponse) GetTotalCount() int32

func (*ListWorkersResponse) GetWorkers 

func (x *ListWorkersResponse) GetWorkers() []*WorkerInfo

func (*ListWorkersResponse) ProtoMessage 

func (*ListWorkersResponse) ProtoMessage()

func (*ListWorkersResponse) ProtoReflect 

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

func (*ListWorkersResponse) Reset 

func (x *ListWorkersResponse) Reset()

func (*ListWorkersResponse) String 

func (x *ListWorkersResponse) String() string

type LoadAgentStateRequest 

type LoadAgentStateRequest struct {
	AgentId *AgentID `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

LoadAgentStateRequest loads the state of an agent

func (*LoadAgentStateRequest) Descriptor deprecated 

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

Deprecated: Use LoadAgentStateRequest.ProtoReflect.Descriptor instead.

func (*LoadAgentStateRequest) GetAgentId 

func (x *LoadAgentStateRequest) GetAgentId() *AgentID

func (*LoadAgentStateRequest) ProtoMessage 

func (*LoadAgentStateRequest) ProtoMessage()

func (*LoadAgentStateRequest) ProtoReflect 

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

func (*LoadAgentStateRequest) Reset 

func (x *LoadAgentStateRequest) Reset()

func (*LoadAgentStateRequest) String 

func (x *LoadAgentStateRequest) String() string

type LoadAgentStateResponse 

type LoadAgentStateResponse struct {
	Success      bool                 `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string               `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	State        map[string]*any1.Any `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoadAgentStateResponse) Descriptor deprecated 

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

Deprecated: Use LoadAgentStateResponse.ProtoReflect.Descriptor instead.

func (*LoadAgentStateResponse) GetErrorMessage 

func (x *LoadAgentStateResponse) GetErrorMessage() string

func (*LoadAgentStateResponse) GetState 

func (x *LoadAgentStateResponse) GetState() map[string]*any1.Any

func (*LoadAgentStateResponse) GetSuccess 

func (x *LoadAgentStateResponse) GetSuccess() bool

func (*LoadAgentStateResponse) ProtoMessage 

func (*LoadAgentStateResponse) ProtoMessage()

func (*LoadAgentStateResponse) ProtoReflect 

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

func (*LoadAgentStateResponse) Reset 

func (x *LoadAgentStateResponse) Reset()

func (*LoadAgentStateResponse) String 

func (x *LoadAgentStateResponse) String() string

type Message 

type Message struct {
	Id        string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type      string               `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Content   *any1.Any            `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Metadata  map[string]*any1.Any `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message represents a message that can be processed by agents

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetContent 

func (x *Message) GetContent() *any1.Any

func (*Message) GetId 

func (x *Message) GetId() string

func (*Message) GetMetadata 

func (x *Message) GetMetadata() map[string]*any1.Any

func (*Message) GetTimestamp 

func (x *Message) GetTimestamp() *timestamp.Timestamp

func (*Message) GetType 

func (x *Message) GetType() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageContext 

type MessageContext struct {
	Sender    *AgentID             `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	TopicId   string               `protobuf:"bytes,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	IsRpc     bool                 `protobuf:"varint,3,opt,name=is_rpc,json=isRpc,proto3" json:"is_rpc,omitempty"`
	MessageId string               `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Metadata  map[string]*any1.Any `` /* 143-byte string literal not displayed */
	RequestId string               `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	TraceId   string               `protobuf:"bytes,7,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,8,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

MessageContext provides contextual information for message processing

func (*MessageContext) Descriptor deprecated 

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

Deprecated: Use MessageContext.ProtoReflect.Descriptor instead.

func (*MessageContext) GetIsRpc 

func (x *MessageContext) GetIsRpc() bool

func (*MessageContext) GetMessageId 

func (x *MessageContext) GetMessageId() string

func (*MessageContext) GetMetadata 

func (x *MessageContext) GetMetadata() map[string]*any1.Any

func (*MessageContext) GetRequestId 

func (x *MessageContext) GetRequestId() string

func (*MessageContext) GetSender 

func (x *MessageContext) GetSender() *AgentID

func (*MessageContext) GetTimestamp 

func (x *MessageContext) GetTimestamp() *timestamp.Timestamp

func (*MessageContext) GetTopicId 

func (x *MessageContext) GetTopicId() string

func (*MessageContext) GetTraceId 

func (x *MessageContext) GetTraceId() string

func (*MessageContext) ProtoMessage 

func (*MessageContext) ProtoMessage()

func (*MessageContext) ProtoReflect 

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

func (*MessageContext) Reset 

func (x *MessageContext) Reset()

func (*MessageContext) String 

func (x *MessageContext) String() string

type PlaceAgentRequest 

type PlaceAgentRequest struct {
	AgentId          *AgentID             `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Metadata         *AgentMetadata       `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Config           map[string]*any1.Any `` /* 139-byte string literal not displayed */
	Strategy         PlacementStrategy    `protobuf:"varint,4,opt,name=strategy,proto3,enum=goautogen.api.v1.PlacementStrategy" json:"strategy,omitempty"`
	PreferredWorkers []string             `protobuf:"bytes,5,rep,name=preferred_workers,json=preferredWorkers,proto3" json:"preferred_workers,omitempty"`
	// contains filtered or unexported fields
}

PlaceAgentRequest places an agent on a worker

func (*PlaceAgentRequest) Descriptor deprecated 

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

Deprecated: Use PlaceAgentRequest.ProtoReflect.Descriptor instead.

func (*PlaceAgentRequest) GetAgentId 

func (x *PlaceAgentRequest) GetAgentId() *AgentID

func (*PlaceAgentRequest) GetConfig 

func (x *PlaceAgentRequest) GetConfig() map[string]*any1.Any

func (*PlaceAgentRequest) GetMetadata 

func (x *PlaceAgentRequest) GetMetadata() *AgentMetadata

func (*PlaceAgentRequest) GetPreferredWorkers 

func (x *PlaceAgentRequest) GetPreferredWorkers() []string

func (*PlaceAgentRequest) GetStrategy 

func (x *PlaceAgentRequest) GetStrategy() PlacementStrategy

func (*PlaceAgentRequest) ProtoMessage 

func (*PlaceAgentRequest) ProtoMessage()

func (*PlaceAgentRequest) ProtoReflect 

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

func (*PlaceAgentRequest) Reset 

func (x *PlaceAgentRequest) Reset()

func (*PlaceAgentRequest) String 

func (x *PlaceAgentRequest) String() string

type PlaceAgentResponse 

type PlaceAgentResponse struct {
	Success          bool         `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage     string       `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	AssignedWorkerId string       `protobuf:"bytes,3,opt,name=assigned_worker_id,json=assignedWorkerId,proto3" json:"assigned_worker_id,omitempty"`
	AgentStatus      *AgentStatus `protobuf:"bytes,4,opt,name=agent_status,json=agentStatus,proto3" json:"agent_status,omitempty"`
	// contains filtered or unexported fields
}

func (*PlaceAgentResponse) Descriptor deprecated 

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

Deprecated: Use PlaceAgentResponse.ProtoReflect.Descriptor instead.

func (*PlaceAgentResponse) GetAgentStatus 

func (x *PlaceAgentResponse) GetAgentStatus() *AgentStatus

func (*PlaceAgentResponse) GetAssignedWorkerId 

func (x *PlaceAgentResponse) GetAssignedWorkerId() string

func (*PlaceAgentResponse) GetErrorMessage 

func (x *PlaceAgentResponse) GetErrorMessage() string

func (*PlaceAgentResponse) GetSuccess 

func (x *PlaceAgentResponse) GetSuccess() bool

func (*PlaceAgentResponse) ProtoMessage 

func (*PlaceAgentResponse) ProtoMessage()

func (*PlaceAgentResponse) ProtoReflect 

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

func (*PlaceAgentResponse) Reset 

func (x *PlaceAgentResponse) Reset()

func (*PlaceAgentResponse) String 

func (x *PlaceAgentResponse) String() string

type PlacementStrategy 

type PlacementStrategy int32
const (
	PlacementStrategy_PLACEMENT_STRATEGY_UNSPECIFIED    PlacementStrategy = 0
	PlacementStrategy_PLACEMENT_STRATEGY_ROUND_ROBIN    PlacementStrategy = 1
	PlacementStrategy_PLACEMENT_STRATEGY_LEAST_LOADED   PlacementStrategy = 2
	PlacementStrategy_PLACEMENT_STRATEGY_RESOURCE_AWARE PlacementStrategy = 3
	PlacementStrategy_PLACEMENT_STRATEGY_AFFINITY       PlacementStrategy = 4
)

func (PlacementStrategy) Descriptor 

func (PlacementStrategy) Descriptor() protoreflect.EnumDescriptor

func (PlacementStrategy) Enum 

func (x PlacementStrategy) Enum() *PlacementStrategy

func (PlacementStrategy) EnumDescriptor deprecated 

func (PlacementStrategy) EnumDescriptor() ([]byte, []int)

Deprecated: Use PlacementStrategy.Descriptor instead.

func (PlacementStrategy) Number 

func (x PlacementStrategy) Number() protoreflect.EnumNumber

func (PlacementStrategy) String 

func (x PlacementStrategy) String() string

func (PlacementStrategy) Type 

func (PlacementStrategy) Type() protoreflect.EnumType

type RegisterAgentRequest 

type RegisterAgentRequest struct {
	AgentId  *AgentID             `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Metadata *AgentMetadata       `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Config   map[string]*any1.Any `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

RegisterAgentRequest registers a new agent on the worker

func (*RegisterAgentRequest) Descriptor deprecated 

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

Deprecated: Use RegisterAgentRequest.ProtoReflect.Descriptor instead.

func (*RegisterAgentRequest) GetAgentId 

func (x *RegisterAgentRequest) GetAgentId() *AgentID

func (*RegisterAgentRequest) GetConfig 

func (x *RegisterAgentRequest) GetConfig() map[string]*any1.Any

func (*RegisterAgentRequest) GetMetadata 

func (x *RegisterAgentRequest) GetMetadata() *AgentMetadata

func (*RegisterAgentRequest) ProtoMessage 

func (*RegisterAgentRequest) ProtoMessage()

func (*RegisterAgentRequest) ProtoReflect 

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

func (*RegisterAgentRequest) Reset 

func (x *RegisterAgentRequest) Reset()

func (*RegisterAgentRequest) String 

func (x *RegisterAgentRequest) String() string

type RegisterAgentResponse 

type RegisterAgentResponse struct {
	Success      bool         `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string       `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Status       *AgentStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterAgentResponse) Descriptor deprecated 

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

Deprecated: Use RegisterAgentResponse.ProtoReflect.Descriptor instead.

func (*RegisterAgentResponse) GetErrorMessage 

func (x *RegisterAgentResponse) GetErrorMessage() string

func (*RegisterAgentResponse) GetStatus 

func (x *RegisterAgentResponse) GetStatus() *AgentStatus

func (*RegisterAgentResponse) GetSuccess 

func (x *RegisterAgentResponse) GetSuccess() bool

func (*RegisterAgentResponse) ProtoMessage 

func (*RegisterAgentResponse) ProtoMessage()

func (*RegisterAgentResponse) ProtoReflect 

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

func (*RegisterAgentResponse) Reset 

func (x *RegisterAgentResponse) Reset()

func (*RegisterAgentResponse) String 

func (x *RegisterAgentResponse) String() string

type RegisterWorkerRequest 

type RegisterWorkerRequest struct {
	WorkerId     string              `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Address      string              `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Port         int32               `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Capabilities *WorkerCapabilities `protobuf:"bytes,4,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	Metadata     map[string]string   `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

RegisterWorkerRequest registers a new worker

func (*RegisterWorkerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterWorkerRequest.ProtoReflect.Descriptor instead.

func (*RegisterWorkerRequest) GetAddress 

func (x *RegisterWorkerRequest) GetAddress() string

func (*RegisterWorkerRequest) GetCapabilities 

func (x *RegisterWorkerRequest) GetCapabilities() *WorkerCapabilities

func (*RegisterWorkerRequest) GetMetadata 

func (x *RegisterWorkerRequest) GetMetadata() map[string]string

func (*RegisterWorkerRequest) GetPort 

func (x *RegisterWorkerRequest) GetPort() int32

func (*RegisterWorkerRequest) GetWorkerId 

func (x *RegisterWorkerRequest) GetWorkerId() string

func (*RegisterWorkerRequest) ProtoMessage 

func (*RegisterWorkerRequest) ProtoMessage()

func (*RegisterWorkerRequest) ProtoReflect 

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

func (*RegisterWorkerRequest) Reset 

func (x *RegisterWorkerRequest) Reset()

func (*RegisterWorkerRequest) String 

func (x *RegisterWorkerRequest) String() string

type RegisterWorkerResponse 

type RegisterWorkerResponse struct {
	Success           bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage      string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	RegistrationToken string `protobuf:"bytes,3,opt,name=registration_token,json=registrationToken,proto3" json:"registration_token,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterWorkerResponse) Descriptor deprecated 

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

Deprecated: Use RegisterWorkerResponse.ProtoReflect.Descriptor instead.

func (*RegisterWorkerResponse) GetErrorMessage 

func (x *RegisterWorkerResponse) GetErrorMessage() string

func (*RegisterWorkerResponse) GetRegistrationToken 

func (x *RegisterWorkerResponse) GetRegistrationToken() string

func (*RegisterWorkerResponse) GetSuccess 

func (x *RegisterWorkerResponse) GetSuccess() bool

func (*RegisterWorkerResponse) ProtoMessage 

func (*RegisterWorkerResponse) ProtoMessage()

func (*RegisterWorkerResponse) ProtoReflect 

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

func (*RegisterWorkerResponse) Reset 

func (x *RegisterWorkerResponse) Reset()

func (*RegisterWorkerResponse) String 

func (x *RegisterWorkerResponse) String() string

type RouteMessageRequest 

type RouteMessageRequest struct {
	TargetAgentId *AgentID        `protobuf:"bytes,1,opt,name=target_agent_id,json=targetAgentId,proto3" json:"target_agent_id,omitempty"`
	Message       *Message        `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Context       *MessageContext `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	TimeoutMs     int64           `protobuf:"varint,4,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"`
	// contains filtered or unexported fields
}

RouteMessageRequest routes a message to an agent

func (*RouteMessageRequest) Descriptor deprecated 

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

Deprecated: Use RouteMessageRequest.ProtoReflect.Descriptor instead.

func (*RouteMessageRequest) GetContext 

func (x *RouteMessageRequest) GetContext() *MessageContext

func (*RouteMessageRequest) GetMessage 

func (x *RouteMessageRequest) GetMessage() *Message

func (*RouteMessageRequest) GetTargetAgentId 

func (x *RouteMessageRequest) GetTargetAgentId() *AgentID

func (*RouteMessageRequest) GetTimeoutMs 

func (x *RouteMessageRequest) GetTimeoutMs() int64

func (*RouteMessageRequest) ProtoMessage 

func (*RouteMessageRequest) ProtoMessage()

func (*RouteMessageRequest) ProtoReflect 

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

func (*RouteMessageRequest) Reset 

func (x *RouteMessageRequest) Reset()

func (*RouteMessageRequest) String 

func (x *RouteMessageRequest) String() string

type RouteMessageResponse 

type RouteMessageResponse struct {
	Success         bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage    string   `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ResponseMessage *Message `protobuf:"bytes,3,opt,name=response_message,json=responseMessage,proto3" json:"response_message,omitempty"`
	RoutedToWorker  string   `protobuf:"bytes,4,opt,name=routed_to_worker,json=routedToWorker,proto3" json:"routed_to_worker,omitempty"`
	ExecutionTimeMs int64    `protobuf:"varint,5,opt,name=execution_time_ms,json=executionTimeMs,proto3" json:"execution_time_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteMessageResponse) Descriptor deprecated 

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

Deprecated: Use RouteMessageResponse.ProtoReflect.Descriptor instead.

func (*RouteMessageResponse) GetErrorMessage 

func (x *RouteMessageResponse) GetErrorMessage() string

func (*RouteMessageResponse) GetExecutionTimeMs 

func (x *RouteMessageResponse) GetExecutionTimeMs() int64

func (*RouteMessageResponse) GetResponseMessage 

func (x *RouteMessageResponse) GetResponseMessage() *Message

func (*RouteMessageResponse) GetRoutedToWorker 

func (x *RouteMessageResponse) GetRoutedToWorker() string

func (*RouteMessageResponse) GetSuccess 

func (x *RouteMessageResponse) GetSuccess() bool

func (*RouteMessageResponse) ProtoMessage 

func (*RouteMessageResponse) ProtoMessage()

func (*RouteMessageResponse) ProtoReflect 

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

func (*RouteMessageResponse) Reset 

func (x *RouteMessageResponse) Reset()

func (*RouteMessageResponse) String 

func (x *RouteMessageResponse) String() string

type RuntimeServiceClient 

type RuntimeServiceClient interface {
	// RegisterWorker registers a new worker with the runtime
	RegisterWorker(ctx context.Context, in *RegisterWorkerRequest, opts ...grpc.CallOption) (*RegisterWorkerResponse, error)
	// UnregisterWorker removes a worker from the runtime
	UnregisterWorker(ctx context.Context, in *UnregisterWorkerRequest, opts ...grpc.CallOption) (*UnregisterWorkerResponse, error)
	// GetWorkerInfo returns information about a specific worker
	GetWorkerInfo(ctx context.Context, in *GetWorkerInfoRequest, opts ...grpc.CallOption) (*GetWorkerInfoResponse, error)
	// ListWorkers returns all registered workers
	ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error)
	// PlaceAgent places an agent on an appropriate worker
	PlaceAgent(ctx context.Context, in *PlaceAgentRequest, opts ...grpc.CallOption) (*PlaceAgentResponse, error)
	// RouteMessage routes a message to the appropriate agent
	RouteMessage(ctx context.Context, in *RouteMessageRequest, opts ...grpc.CallOption) (*RouteMessageResponse, error)
	// StartConversation starts a new conversation between agents
	StartConversation(ctx context.Context, in *StartConversationRequest, opts ...grpc.CallOption) (*StartConversationResponse, error)
	// EndConversation ends an active conversation
	EndConversation(ctx context.Context, in *EndConversationRequest, opts ...grpc.CallOption) (*EndConversationResponse, error)
	// GetConversation returns conversation details
	GetConversation(ctx context.Context, in *GetConversationRequest, opts ...grpc.CallOption) (*GetConversationResponse, error)
	// ListConversations returns all active conversations
	ListConversations(ctx context.Context, in *ListConversationsRequest, opts ...grpc.CallOption) (*ListConversationsResponse, error)
	// StreamConversationEvents streams events from conversations
	StreamConversationEvents(ctx context.Context, in *StreamConversationEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ConversationEvent], error)
	// GetRuntimeStatus returns the overall runtime status
	GetRuntimeStatus(ctx context.Context, in *GetRuntimeStatusRequest, opts ...grpc.CallOption) (*GetRuntimeStatusResponse, error)
}

RuntimeServiceClient is the client API for RuntimeService 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.

RuntimeService defines the service for managing the distributed runtime

func NewRuntimeServiceClient 

func NewRuntimeServiceClient(cc grpc.ClientConnInterface) RuntimeServiceClient

type RuntimeServiceServer 

type RuntimeServiceServer interface {
	// RegisterWorker registers a new worker with the runtime
	RegisterWorker(context.Context, *RegisterWorkerRequest) (*RegisterWorkerResponse, error)
	// UnregisterWorker removes a worker from the runtime
	UnregisterWorker(context.Context, *UnregisterWorkerRequest) (*UnregisterWorkerResponse, error)
	// GetWorkerInfo returns information about a specific worker
	GetWorkerInfo(context.Context, *GetWorkerInfoRequest) (*GetWorkerInfoResponse, error)
	// ListWorkers returns all registered workers
	ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
	// PlaceAgent places an agent on an appropriate worker
	PlaceAgent(context.Context, *PlaceAgentRequest) (*PlaceAgentResponse, error)
	// RouteMessage routes a message to the appropriate agent
	RouteMessage(context.Context, *RouteMessageRequest) (*RouteMessageResponse, error)
	// StartConversation starts a new conversation between agents
	StartConversation(context.Context, *StartConversationRequest) (*StartConversationResponse, error)
	// EndConversation ends an active conversation
	EndConversation(context.Context, *EndConversationRequest) (*EndConversationResponse, error)
	// GetConversation returns conversation details
	GetConversation(context.Context, *GetConversationRequest) (*GetConversationResponse, error)
	// ListConversations returns all active conversations
	ListConversations(context.Context, *ListConversationsRequest) (*ListConversationsResponse, error)
	// StreamConversationEvents streams events from conversations
	StreamConversationEvents(*StreamConversationEventsRequest, grpc.ServerStreamingServer[ConversationEvent]) error
	// GetRuntimeStatus returns the overall runtime status
	GetRuntimeStatus(context.Context, *GetRuntimeStatusRequest) (*GetRuntimeStatusResponse, error)
	// contains filtered or unexported methods
}

RuntimeServiceServer is the server API for RuntimeService service. All implementations must embed UnimplementedRuntimeServiceServer for forward compatibility.

RuntimeService defines the service for managing the distributed runtime

type RuntimeService_StreamConversationEventsClient 

type RuntimeService_StreamConversationEventsClient = grpc.ServerStreamingClient[ConversationEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RuntimeService_StreamConversationEventsServer 

type RuntimeService_StreamConversationEventsServer = grpc.ServerStreamingServer[ConversationEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RuntimeState 

type RuntimeState int32
const (
	RuntimeState_RUNTIME_STATE_UNSPECIFIED   RuntimeState = 0
	RuntimeState_RUNTIME_STATE_STARTING      RuntimeState = 1
	RuntimeState_RUNTIME_STATE_READY         RuntimeState = 2
	RuntimeState_RUNTIME_STATE_DEGRADED      RuntimeState = 3
	RuntimeState_RUNTIME_STATE_SHUTTING_DOWN RuntimeState = 4
	RuntimeState_RUNTIME_STATE_STOPPED       RuntimeState = 5
)

func (RuntimeState) Descriptor 

func (RuntimeState) Descriptor() protoreflect.EnumDescriptor

func (RuntimeState) Enum 

func (x RuntimeState) Enum() *RuntimeState

func (RuntimeState) EnumDescriptor deprecated 

func (RuntimeState) EnumDescriptor() ([]byte, []int)

Deprecated: Use RuntimeState.Descriptor instead.

func (RuntimeState) Number 

func (x RuntimeState) Number() protoreflect.EnumNumber

func (RuntimeState) String 

func (x RuntimeState) String() string

func (RuntimeState) Type 

func (RuntimeState) Type() protoreflect.EnumType

type RuntimeStatus 

type RuntimeStatus struct {
	State               RuntimeState         `protobuf:"varint,1,opt,name=state,proto3,enum=goautogen.api.v1.RuntimeState" json:"state,omitempty"`
	TotalWorkers        int32                `protobuf:"varint,2,opt,name=total_workers,json=totalWorkers,proto3" json:"total_workers,omitempty"`
	HealthyWorkers      int32                `protobuf:"varint,3,opt,name=healthy_workers,json=healthyWorkers,proto3" json:"healthy_workers,omitempty"`
	TotalAgents         int32                `protobuf:"varint,4,opt,name=total_agents,json=totalAgents,proto3" json:"total_agents,omitempty"`
	ActiveConversations int32                `protobuf:"varint,5,opt,name=active_conversations,json=activeConversations,proto3" json:"active_conversations,omitempty"`
	MessagesPerSecond   int64                `protobuf:"varint,6,opt,name=messages_per_second,json=messagesPerSecond,proto3" json:"messages_per_second,omitempty"`
	StartedAt           *timestamp.Timestamp `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	LastUpdated         *timestamp.Timestamp `protobuf:"bytes,8,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	Metrics             map[string]*any1.Any `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

RuntimeStatus represents the overall runtime status

func (*RuntimeStatus) Descriptor deprecated 

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

Deprecated: Use RuntimeStatus.ProtoReflect.Descriptor instead.

func (*RuntimeStatus) GetActiveConversations 

func (x *RuntimeStatus) GetActiveConversations() int32

func (*RuntimeStatus) GetHealthyWorkers 

func (x *RuntimeStatus) GetHealthyWorkers() int32

func (*RuntimeStatus) GetLastUpdated 

func (x *RuntimeStatus) GetLastUpdated() *timestamp.Timestamp

func (*RuntimeStatus) GetMessagesPerSecond 

func (x *RuntimeStatus) GetMessagesPerSecond() int64

func (*RuntimeStatus) GetMetrics 

func (x *RuntimeStatus) GetMetrics() map[string]*any1.Any

func (*RuntimeStatus) GetStartedAt 

func (x *RuntimeStatus) GetStartedAt() *timestamp.Timestamp

func (*RuntimeStatus) GetState 

func (x *RuntimeStatus) GetState() RuntimeState

func (*RuntimeStatus) GetTotalAgents 

func (x *RuntimeStatus) GetTotalAgents() int32

func (*RuntimeStatus) GetTotalWorkers 

func (x *RuntimeStatus) GetTotalWorkers() int32

func (*RuntimeStatus) ProtoMessage 

func (*RuntimeStatus) ProtoMessage()

func (*RuntimeStatus) ProtoReflect 

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

func (*RuntimeStatus) Reset 

func (x *RuntimeStatus) Reset()

func (*RuntimeStatus) String 

func (x *RuntimeStatus) String() string

type SaveAgentStateRequest 

type SaveAgentStateRequest struct {
	AgentId *AgentID             `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	State   map[string]*any1.Any `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

SaveAgentStateRequest saves the current state of an agent

func (*SaveAgentStateRequest) Descriptor deprecated 

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

Deprecated: Use SaveAgentStateRequest.ProtoReflect.Descriptor instead.

func (*SaveAgentStateRequest) GetAgentId 

func (x *SaveAgentStateRequest) GetAgentId() *AgentID

func (*SaveAgentStateRequest) GetState 

func (x *SaveAgentStateRequest) GetState() map[string]*any1.Any

func (*SaveAgentStateRequest) ProtoMessage 

func (*SaveAgentStateRequest) ProtoMessage()

func (*SaveAgentStateRequest) ProtoReflect 

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

func (*SaveAgentStateRequest) Reset 

func (x *SaveAgentStateRequest) Reset()

func (*SaveAgentStateRequest) String 

func (x *SaveAgentStateRequest) String() string

type SaveAgentStateResponse 

type SaveAgentStateResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveAgentStateResponse) Descriptor deprecated 

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

Deprecated: Use SaveAgentStateResponse.ProtoReflect.Descriptor instead.

func (*SaveAgentStateResponse) GetErrorMessage 

func (x *SaveAgentStateResponse) GetErrorMessage() string

func (*SaveAgentStateResponse) GetSuccess 

func (x *SaveAgentStateResponse) GetSuccess() bool

func (*SaveAgentStateResponse) ProtoMessage 

func (*SaveAgentStateResponse) ProtoMessage()

func (*SaveAgentStateResponse) ProtoReflect 

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

func (*SaveAgentStateResponse) Reset 

func (x *SaveAgentStateResponse) Reset()

func (*SaveAgentStateResponse) String 

func (x *SaveAgentStateResponse) String() string

type StartConversationRequest 

type StartConversationRequest struct {
	Participants []*AgentID           `protobuf:"bytes,1,rep,name=participants,proto3" json:"participants,omitempty"`
	Metadata     map[string]*any1.Any `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

StartConversationRequest starts a new conversation

func (*StartConversationRequest) Descriptor deprecated 

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

Deprecated: Use StartConversationRequest.ProtoReflect.Descriptor instead.

func (*StartConversationRequest) GetMetadata 

func (x *StartConversationRequest) GetMetadata() map[string]*any1.Any

func (*StartConversationRequest) GetParticipants 

func (x *StartConversationRequest) GetParticipants() []*AgentID

func (*StartConversationRequest) ProtoMessage 

func (*StartConversationRequest) ProtoMessage()

func (*StartConversationRequest) ProtoReflect 

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

func (*StartConversationRequest) Reset 

func (x *StartConversationRequest) Reset()

func (*StartConversationRequest) String 

func (x *StartConversationRequest) String() string

type StartConversationResponse 

type StartConversationResponse struct {
	Success        bool            `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage   string          `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ConversationId *ConversationID `protobuf:"bytes,3,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartConversationResponse) Descriptor deprecated 

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

Deprecated: Use StartConversationResponse.ProtoReflect.Descriptor instead.

func (*StartConversationResponse) GetConversationId 

func (x *StartConversationResponse) GetConversationId() *ConversationID

func (*StartConversationResponse) GetErrorMessage 

func (x *StartConversationResponse) GetErrorMessage() string

func (*StartConversationResponse) GetSuccess 

func (x *StartConversationResponse) GetSuccess() bool

func (*StartConversationResponse) ProtoMessage 

func (*StartConversationResponse) ProtoMessage()

func (*StartConversationResponse) ProtoReflect 

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

func (*StartConversationResponse) Reset 

func (x *StartConversationResponse) Reset()

func (*StartConversationResponse) String 

func (x *StartConversationResponse) String() string

type StreamCloseRequest 

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

func (*StreamCloseRequest) Descriptor deprecated 

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

Deprecated: Use StreamCloseRequest.ProtoReflect.Descriptor instead.

func (*StreamCloseRequest) GetReason 

func (x *StreamCloseRequest) GetReason() string

func (*StreamCloseRequest) ProtoMessage 

func (*StreamCloseRequest) ProtoMessage()

func (*StreamCloseRequest) ProtoReflect 

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

func (*StreamCloseRequest) Reset 

func (x *StreamCloseRequest) Reset()

func (*StreamCloseRequest) String 

func (x *StreamCloseRequest) String() string

type StreamCloseResponse 

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

func (*StreamCloseResponse) Descriptor deprecated 

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

Deprecated: Use StreamCloseResponse.ProtoReflect.Descriptor instead.

func (*StreamCloseResponse) GetReason 

func (x *StreamCloseResponse) GetReason() string

func (*StreamCloseResponse) ProtoMessage 

func (*StreamCloseResponse) ProtoMessage()

func (*StreamCloseResponse) ProtoReflect 

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

func (*StreamCloseResponse) Reset 

func (x *StreamCloseResponse) Reset()

func (*StreamCloseResponse) String 

func (x *StreamCloseResponse) String() string

type StreamConversationEventsRequest 

type StreamConversationEventsRequest struct {
	ConversationId *ConversationID      `protobuf:"bytes,1,opt,name=conversation_id,json=conversationId,proto3" json:"conversation_id,omitempty"`
	StartTime      *timestamp.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

StreamConversationEventsRequest streams conversation events

func (*StreamConversationEventsRequest) Descriptor deprecated 

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

Deprecated: Use StreamConversationEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamConversationEventsRequest) GetConversationId 

func (x *StreamConversationEventsRequest) GetConversationId() *ConversationID

func (*StreamConversationEventsRequest) GetStartTime 

func (x *StreamConversationEventsRequest) GetStartTime() *timestamp.Timestamp

func (*StreamConversationEventsRequest) ProtoMessage 

func (*StreamConversationEventsRequest) ProtoMessage()

func (*StreamConversationEventsRequest) ProtoReflect 

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

func (*StreamConversationEventsRequest) Reset 

func (x *StreamConversationEventsRequest) Reset()

func (*StreamConversationEventsRequest) String 

func (x *StreamConversationEventsRequest) String() string

type StreamErrorResponse 

type StreamErrorResponse struct {
	ErrorMessage string `protobuf:"bytes,1,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ErrorCode    string `protobuf:"bytes,2,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamErrorResponse) Descriptor deprecated 

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

Deprecated: Use StreamErrorResponse.ProtoReflect.Descriptor instead.

func (*StreamErrorResponse) GetErrorCode 

func (x *StreamErrorResponse) GetErrorCode() string

func (*StreamErrorResponse) GetErrorMessage 

func (x *StreamErrorResponse) GetErrorMessage() string

func (*StreamErrorResponse) ProtoMessage 

func (*StreamErrorResponse) ProtoMessage()

func (*StreamErrorResponse) ProtoReflect 

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

func (*StreamErrorResponse) Reset 

func (x *StreamErrorResponse) Reset()

func (*StreamErrorResponse) String 

func (x *StreamErrorResponse) String() string

type StreamInitRequest 

type StreamInitRequest struct {
	AgentId *AgentID          `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Headers map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamInitRequest) Descriptor deprecated 

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

Deprecated: Use StreamInitRequest.ProtoReflect.Descriptor instead.

func (*StreamInitRequest) GetAgentId 

func (x *StreamInitRequest) GetAgentId() *AgentID

func (*StreamInitRequest) GetHeaders 

func (x *StreamInitRequest) GetHeaders() map[string]string

func (*StreamInitRequest) ProtoMessage 

func (*StreamInitRequest) ProtoMessage()

func (*StreamInitRequest) ProtoReflect 

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

func (*StreamInitRequest) Reset 

func (x *StreamInitRequest) Reset()

func (*StreamInitRequest) String 

func (x *StreamInitRequest) String() string

type StreamInitResponse 

type StreamInitResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	StreamId     string `protobuf:"bytes,3,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamInitResponse) Descriptor deprecated 

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

Deprecated: Use StreamInitResponse.ProtoReflect.Descriptor instead.

func (*StreamInitResponse) GetErrorMessage 

func (x *StreamInitResponse) GetErrorMessage() string

func (*StreamInitResponse) GetStreamId 

func (x *StreamInitResponse) GetStreamId() string

func (*StreamInitResponse) GetSuccess 

func (x *StreamInitResponse) GetSuccess() bool

func (*StreamInitResponse) ProtoMessage 

func (*StreamInitResponse) ProtoMessage()

func (*StreamInitResponse) ProtoReflect 

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

func (*StreamInitResponse) Reset 

func (x *StreamInitResponse) Reset()

func (*StreamInitResponse) String 

func (x *StreamInitResponse) String() string

type StreamMessageData 

type StreamMessageData struct {
	Message *Message        `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Context *MessageContext `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamMessageData) Descriptor deprecated 

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

Deprecated: Use StreamMessageData.ProtoReflect.Descriptor instead.

func (*StreamMessageData) GetContext 

func (x *StreamMessageData) GetContext() *MessageContext

func (*StreamMessageData) GetMessage 

func (x *StreamMessageData) GetMessage() *Message

func (*StreamMessageData) ProtoMessage 

func (*StreamMessageData) ProtoMessage()

func (*StreamMessageData) ProtoReflect 

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

func (*StreamMessageData) Reset 

func (x *StreamMessageData) Reset()

func (*StreamMessageData) String 

func (x *StreamMessageData) String() string

type StreamMessageRequest 

type StreamMessageRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*StreamMessageRequest_Init
	//	*StreamMessageRequest_Message
	//	*StreamMessageRequest_Close
	Request isStreamMessageRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

StreamMessageRequest for bidirectional streaming

func (*StreamMessageRequest) Descriptor deprecated 

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

Deprecated: Use StreamMessageRequest.ProtoReflect.Descriptor instead.

func (*StreamMessageRequest) GetClose 

func (x *StreamMessageRequest) GetClose() *StreamCloseRequest

func (*StreamMessageRequest) GetInit 

func (x *StreamMessageRequest) GetInit() *StreamInitRequest

func (*StreamMessageRequest) GetMessage 

func (x *StreamMessageRequest) GetMessage() *StreamMessageData

func (*StreamMessageRequest) GetRequest 

func (x *StreamMessageRequest) GetRequest() isStreamMessageRequest_Request

func (*StreamMessageRequest) ProtoMessage 

func (*StreamMessageRequest) ProtoMessage()

func (*StreamMessageRequest) ProtoReflect 

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

func (*StreamMessageRequest) Reset 

func (x *StreamMessageRequest) Reset()

func (*StreamMessageRequest) String 

func (x *StreamMessageRequest) String() string

type StreamMessageRequest_Close 

type StreamMessageRequest_Close struct {
	Close *StreamCloseRequest `protobuf:"bytes,3,opt,name=close,proto3,oneof"`
}

type StreamMessageRequest_Init 

type StreamMessageRequest_Init struct {
	Init *StreamInitRequest `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type StreamMessageRequest_Message 

type StreamMessageRequest_Message struct {
	Message *StreamMessageData `protobuf:"bytes,2,opt,name=message,proto3,oneof"`
}

type StreamMessageResponse 

type StreamMessageResponse struct {

	// Types that are valid to be assigned to Response:
	//
	//	*StreamMessageResponse_Init
	//	*StreamMessageResponse_Message
	//	*StreamMessageResponse_Error
	//	*StreamMessageResponse_Close
	Response isStreamMessageResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*StreamMessageResponse) Descriptor deprecated 

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

Deprecated: Use StreamMessageResponse.ProtoReflect.Descriptor instead.

func (*StreamMessageResponse) GetClose 

func (x *StreamMessageResponse) GetClose() *StreamCloseResponse

func (*StreamMessageResponse) GetError 

func (x *StreamMessageResponse) GetError() *StreamErrorResponse

func (*StreamMessageResponse) GetInit 

func (x *StreamMessageResponse) GetInit() *StreamInitResponse

func (*StreamMessageResponse) GetMessage 

func (x *StreamMessageResponse) GetMessage() *StreamMessageData

func (*StreamMessageResponse) GetResponse 

func (x *StreamMessageResponse) GetResponse() isStreamMessageResponse_Response

func (*StreamMessageResponse) ProtoMessage 

func (*StreamMessageResponse) ProtoMessage()

func (*StreamMessageResponse) ProtoReflect 

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

func (*StreamMessageResponse) Reset 

func (x *StreamMessageResponse) Reset()

func (*StreamMessageResponse) String 

func (x *StreamMessageResponse) String() string

type StreamMessageResponse_Close 

type StreamMessageResponse_Close struct {
	Close *StreamCloseResponse `protobuf:"bytes,4,opt,name=close,proto3,oneof"`
}

type StreamMessageResponse_Error 

type StreamMessageResponse_Error struct {
	Error *StreamErrorResponse `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}

type StreamMessageResponse_Init 

type StreamMessageResponse_Init struct {
	Init *StreamInitResponse `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type StreamMessageResponse_Message 

type StreamMessageResponse_Message struct {
	Message *StreamMessageData `protobuf:"bytes,2,opt,name=message,proto3,oneof"`
}

type UnimplementedAgentWorkerServiceServer 

type UnimplementedAgentWorkerServiceServer struct{}

UnimplementedAgentWorkerServiceServer 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.

func (UnimplementedAgentWorkerServiceServer) ExecuteMessage 

func (UnimplementedAgentWorkerServiceServer) ExecuteMessage(context.Context, *ExecuteMessageRequest) (*ExecuteMessageResponse, error)

func (UnimplementedAgentWorkerServiceServer) GetAgentStatus 

func (UnimplementedAgentWorkerServiceServer) GetAgentStatus(context.Context, *GetAgentStatusRequest) (*GetAgentStatusResponse, error)

func (UnimplementedAgentWorkerServiceServer) ListAgents 

func (UnimplementedAgentWorkerServiceServer) ListAgents(context.Context, *ListAgentsRequest) (*ListAgentsResponse, error)

func (UnimplementedAgentWorkerServiceServer) LoadAgentState 

func (UnimplementedAgentWorkerServiceServer) LoadAgentState(context.Context, *LoadAgentStateRequest) (*LoadAgentStateResponse, error)

func (UnimplementedAgentWorkerServiceServer) RegisterAgent 

func (UnimplementedAgentWorkerServiceServer) RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)

func (UnimplementedAgentWorkerServiceServer) SaveAgentState 

func (UnimplementedAgentWorkerServiceServer) SaveAgentState(context.Context, *SaveAgentStateRequest) (*SaveAgentStateResponse, error)

func (UnimplementedAgentWorkerServiceServer) StreamMessages 

func (UnimplementedAgentWorkerServiceServer) StreamMessages(grpc.BidiStreamingServer[StreamMessageRequest, StreamMessageResponse]) error

func (UnimplementedAgentWorkerServiceServer) UnregisterAgent 

func (UnimplementedAgentWorkerServiceServer) UnregisterAgent(context.Context, *UnregisterAgentRequest) (*UnregisterAgentResponse, error)

type UnimplementedHealthServiceServer 

type UnimplementedHealthServiceServer struct{}

UnimplementedHealthServiceServer 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.

func (UnimplementedHealthServiceServer) Check 

func (UnimplementedHealthServiceServer) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

func (UnimplementedHealthServiceServer) GetHealthStatus 

func (UnimplementedHealthServiceServer) GetHealthStatus(context.Context, *GetHealthStatusRequest) (*GetHealthStatusResponse, error)

func (UnimplementedHealthServiceServer) Watch 

func (UnimplementedHealthServiceServer) Watch(*HealthCheckRequest, grpc.ServerStreamingServer[HealthCheckResponse]) error

type UnimplementedRuntimeServiceServer 

type UnimplementedRuntimeServiceServer struct{}

UnimplementedRuntimeServiceServer 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.

func (UnimplementedRuntimeServiceServer) EndConversation 

func (UnimplementedRuntimeServiceServer) EndConversation(context.Context, *EndConversationRequest) (*EndConversationResponse, error)

func (UnimplementedRuntimeServiceServer) GetConversation 

func (UnimplementedRuntimeServiceServer) GetConversation(context.Context, *GetConversationRequest) (*GetConversationResponse, error)

func (UnimplementedRuntimeServiceServer) GetRuntimeStatus 

func (UnimplementedRuntimeServiceServer) GetRuntimeStatus(context.Context, *GetRuntimeStatusRequest) (*GetRuntimeStatusResponse, error)

func (UnimplementedRuntimeServiceServer) GetWorkerInfo 

func (UnimplementedRuntimeServiceServer) GetWorkerInfo(context.Context, *GetWorkerInfoRequest) (*GetWorkerInfoResponse, error)

func (UnimplementedRuntimeServiceServer) ListConversations 

func (UnimplementedRuntimeServiceServer) ListConversations(context.Context, *ListConversationsRequest) (*ListConversationsResponse, error)

func (UnimplementedRuntimeServiceServer) ListWorkers 

func (UnimplementedRuntimeServiceServer) ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)

func (UnimplementedRuntimeServiceServer) PlaceAgent 

func (UnimplementedRuntimeServiceServer) PlaceAgent(context.Context, *PlaceAgentRequest) (*PlaceAgentResponse, error)

func (UnimplementedRuntimeServiceServer) RegisterWorker 

func (UnimplementedRuntimeServiceServer) RegisterWorker(context.Context, *RegisterWorkerRequest) (*RegisterWorkerResponse, error)

func (UnimplementedRuntimeServiceServer) RouteMessage 

func (UnimplementedRuntimeServiceServer) RouteMessage(context.Context, *RouteMessageRequest) (*RouteMessageResponse, error)

func (UnimplementedRuntimeServiceServer) StartConversation 

func (UnimplementedRuntimeServiceServer) StartConversation(context.Context, *StartConversationRequest) (*StartConversationResponse, error)

func (UnimplementedRuntimeServiceServer) StreamConversationEvents 

func (UnimplementedRuntimeServiceServer) StreamConversationEvents(*StreamConversationEventsRequest, grpc.ServerStreamingServer[ConversationEvent]) error

func (UnimplementedRuntimeServiceServer) UnregisterWorker 

func (UnimplementedRuntimeServiceServer) UnregisterWorker(context.Context, *UnregisterWorkerRequest) (*UnregisterWorkerResponse, error)

type UnregisterAgentRequest 

type UnregisterAgentRequest struct {
	AgentId *AgentID `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Force   bool     `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

UnregisterAgentRequest removes an agent from the worker

func (*UnregisterAgentRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterAgentRequest.ProtoReflect.Descriptor instead.

func (*UnregisterAgentRequest) GetAgentId 

func (x *UnregisterAgentRequest) GetAgentId() *AgentID

func (*UnregisterAgentRequest) GetForce 

func (x *UnregisterAgentRequest) GetForce() bool

func (*UnregisterAgentRequest) ProtoMessage 

func (*UnregisterAgentRequest) ProtoMessage()

func (*UnregisterAgentRequest) ProtoReflect 

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

func (*UnregisterAgentRequest) Reset 

func (x *UnregisterAgentRequest) Reset()

func (*UnregisterAgentRequest) String 

func (x *UnregisterAgentRequest) String() string

type UnregisterAgentResponse 

type UnregisterAgentResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterAgentResponse) Descriptor deprecated 

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

Deprecated: Use UnregisterAgentResponse.ProtoReflect.Descriptor instead.

func (*UnregisterAgentResponse) GetErrorMessage 

func (x *UnregisterAgentResponse) GetErrorMessage() string

func (*UnregisterAgentResponse) GetSuccess 

func (x *UnregisterAgentResponse) GetSuccess() bool

func (*UnregisterAgentResponse) ProtoMessage 

func (*UnregisterAgentResponse) ProtoMessage()

func (*UnregisterAgentResponse) ProtoReflect 

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

func (*UnregisterAgentResponse) Reset 

func (x *UnregisterAgentResponse) Reset()

func (*UnregisterAgentResponse) String 

func (x *UnregisterAgentResponse) String() string

type UnregisterWorkerRequest 

type UnregisterWorkerRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Force    bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

UnregisterWorkerRequest removes a worker

func (*UnregisterWorkerRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterWorkerRequest.ProtoReflect.Descriptor instead.

func (*UnregisterWorkerRequest) GetForce 

func (x *UnregisterWorkerRequest) GetForce() bool

func (*UnregisterWorkerRequest) GetWorkerId 

func (x *UnregisterWorkerRequest) GetWorkerId() string

func (*UnregisterWorkerRequest) ProtoMessage 

func (*UnregisterWorkerRequest) ProtoMessage()

func (*UnregisterWorkerRequest) ProtoReflect 

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

func (*UnregisterWorkerRequest) Reset 

func (x *UnregisterWorkerRequest) Reset()

func (*UnregisterWorkerRequest) String 

func (x *UnregisterWorkerRequest) String() string

type UnregisterWorkerResponse 

type UnregisterWorkerResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterWorkerResponse) Descriptor deprecated 

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

Deprecated: Use UnregisterWorkerResponse.ProtoReflect.Descriptor instead.

func (*UnregisterWorkerResponse) GetErrorMessage 

func (x *UnregisterWorkerResponse) GetErrorMessage() string

func (*UnregisterWorkerResponse) GetSuccess 

func (x *UnregisterWorkerResponse) GetSuccess() bool

func (*UnregisterWorkerResponse) ProtoMessage 

func (*UnregisterWorkerResponse) ProtoMessage()

func (*UnregisterWorkerResponse) ProtoReflect 

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

func (*UnregisterWorkerResponse) Reset 

func (x *UnregisterWorkerResponse) Reset()

func (*UnregisterWorkerResponse) String 

func (x *UnregisterWorkerResponse) String() string

type UnsafeAgentWorkerServiceServer 

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

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

type UnsafeHealthServiceServer 

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

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

type UnsafeRuntimeServiceServer 

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

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

type WorkerCapabilities 

type WorkerCapabilities struct {
	MaxAgents             int32             `protobuf:"varint,1,opt,name=max_agents,json=maxAgents,proto3" json:"max_agents,omitempty"`
	MaxConcurrentMessages int32             `` /* 127-byte string literal not displayed */
	SupportedAgentTypes   []string          `protobuf:"bytes,3,rep,name=supported_agent_types,json=supportedAgentTypes,proto3" json:"supported_agent_types,omitempty"`
	SupportedTools        []string          `protobuf:"bytes,4,rep,name=supported_tools,json=supportedTools,proto3" json:"supported_tools,omitempty"`
	Features              map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

WorkerCapabilities describes what a worker can do

func (*WorkerCapabilities) Descriptor deprecated 

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

Deprecated: Use WorkerCapabilities.ProtoReflect.Descriptor instead.

func (*WorkerCapabilities) GetFeatures 

func (x *WorkerCapabilities) GetFeatures() map[string]string

func (*WorkerCapabilities) GetMaxAgents 

func (x *WorkerCapabilities) GetMaxAgents() int32

func (*WorkerCapabilities) GetMaxConcurrentMessages 

func (x *WorkerCapabilities) GetMaxConcurrentMessages() int32

func (*WorkerCapabilities) GetSupportedAgentTypes 

func (x *WorkerCapabilities) GetSupportedAgentTypes() []string

func (*WorkerCapabilities) GetSupportedTools 

func (x *WorkerCapabilities) GetSupportedTools() []string

func (*WorkerCapabilities) ProtoMessage 

func (*WorkerCapabilities) ProtoMessage()

func (*WorkerCapabilities) ProtoReflect 

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

func (*WorkerCapabilities) Reset 

func (x *WorkerCapabilities) Reset()

func (*WorkerCapabilities) String 

func (x *WorkerCapabilities) String() string

type WorkerInfo 

type WorkerInfo struct {
	WorkerId      string               `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Address       string               `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Port          int32                `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Capabilities  *WorkerCapabilities  `protobuf:"bytes,4,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	Status        WorkerStatus         `protobuf:"varint,5,opt,name=status,proto3,enum=goautogen.api.v1.WorkerStatus" json:"status,omitempty"`
	RegisteredAt  *timestamp.Timestamp `protobuf:"bytes,6,opt,name=registered_at,json=registeredAt,proto3" json:"registered_at,omitempty"`
	LastHeartbeat *timestamp.Timestamp `protobuf:"bytes,7,opt,name=last_heartbeat,json=lastHeartbeat,proto3" json:"last_heartbeat,omitempty"`
	Metadata      map[string]string    `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

WorkerInfo contains information about a worker process

func (*WorkerInfo) Descriptor deprecated 

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

Deprecated: Use WorkerInfo.ProtoReflect.Descriptor instead.

func (*WorkerInfo) GetAddress 

func (x *WorkerInfo) GetAddress() string

func (*WorkerInfo) GetCapabilities 

func (x *WorkerInfo) GetCapabilities() *WorkerCapabilities

func (*WorkerInfo) GetLastHeartbeat 

func (x *WorkerInfo) GetLastHeartbeat() *timestamp.Timestamp

func (*WorkerInfo) GetMetadata 

func (x *WorkerInfo) GetMetadata() map[string]string

func (*WorkerInfo) GetPort 

func (x *WorkerInfo) GetPort() int32

func (*WorkerInfo) GetRegisteredAt 

func (x *WorkerInfo) GetRegisteredAt() *timestamp.Timestamp

func (*WorkerInfo) GetStatus 

func (x *WorkerInfo) GetStatus() WorkerStatus

func (*WorkerInfo) GetWorkerId 

func (x *WorkerInfo) GetWorkerId() string

func (*WorkerInfo) ProtoMessage 

func (*WorkerInfo) ProtoMessage()

func (*WorkerInfo) ProtoReflect 

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

func (*WorkerInfo) Reset 

func (x *WorkerInfo) Reset()

func (*WorkerInfo) String 

func (x *WorkerInfo) String() string

type WorkerLoad 

type WorkerLoad struct {
	CurrentAgents     int32                `protobuf:"varint,1,opt,name=current_agents,json=currentAgents,proto3" json:"current_agents,omitempty"`
	CurrentMessages   int32                `protobuf:"varint,2,opt,name=current_messages,json=currentMessages,proto3" json:"current_messages,omitempty"`
	CpuUsage          float64              `protobuf:"fixed64,3,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`
	MemoryUsage       float64              `protobuf:"fixed64,4,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`
	MessagesPerSecond int64                `protobuf:"varint,5,opt,name=messages_per_second,json=messagesPerSecond,proto3" json:"messages_per_second,omitempty"`
	LastUpdated       *timestamp.Timestamp `protobuf:"bytes,6,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	// contains filtered or unexported fields
}

WorkerLoad represents the current load on a worker

func (*WorkerLoad) Descriptor deprecated 

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

Deprecated: Use WorkerLoad.ProtoReflect.Descriptor instead.

func (*WorkerLoad) GetCpuUsage 

func (x *WorkerLoad) GetCpuUsage() float64

func (*WorkerLoad) GetCurrentAgents 

func (x *WorkerLoad) GetCurrentAgents() int32

func (*WorkerLoad) GetCurrentMessages 

func (x *WorkerLoad) GetCurrentMessages() int32

func (*WorkerLoad) GetLastUpdated 

func (x *WorkerLoad) GetLastUpdated() *timestamp.Timestamp

func (*WorkerLoad) GetMemoryUsage 

func (x *WorkerLoad) GetMemoryUsage() float64

func (*WorkerLoad) GetMessagesPerSecond 

func (x *WorkerLoad) GetMessagesPerSecond() int64

func (*WorkerLoad) ProtoMessage 

func (*WorkerLoad) ProtoMessage()

func (*WorkerLoad) ProtoReflect 

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

func (*WorkerLoad) Reset 

func (x *WorkerLoad) Reset()

func (*WorkerLoad) String 

func (x *WorkerLoad) String() string

type WorkerStatus 

type WorkerStatus int32

WorkerStatus represents the current status of a worker 

const (
	WorkerStatus_WORKER_STATUS_UNSPECIFIED   WorkerStatus = 0
	WorkerStatus_WORKER_STATUS_STARTING      WorkerStatus = 1
	WorkerStatus_WORKER_STATUS_READY         WorkerStatus = 2
	WorkerStatus_WORKER_STATUS_BUSY          WorkerStatus = 3
	WorkerStatus_WORKER_STATUS_OVERLOADED    WorkerStatus = 4
	WorkerStatus_WORKER_STATUS_SHUTTING_DOWN WorkerStatus = 5
	WorkerStatus_WORKER_STATUS_UNAVAILABLE   WorkerStatus = 6
)

func (WorkerStatus) Descriptor 

func (WorkerStatus) Descriptor() protoreflect.EnumDescriptor

func (WorkerStatus) Enum 

func (x WorkerStatus) Enum() *WorkerStatus

func (WorkerStatus) EnumDescriptor deprecated 

func (WorkerStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use WorkerStatus.Descriptor instead.

func (WorkerStatus) Number 

func (x WorkerStatus) Number() protoreflect.EnumNumber

func (WorkerStatus) String 

func (x WorkerStatus) String() string

func (WorkerStatus) Type 

func (WorkerStatus) Type() protoreflect.EnumType

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.