proto

Apr 14, 2026

Changes in this version

type DRPCAgentSocketClient

+ UpdateAppStatus func(ctx context.Context, in *proto1.UpdateAppStatusRequest) (*proto1.UpdateAppStatusResponse, error)

type DRPCAgentSocketServer

+ UpdateAppStatus func(context.Context, *proto1.UpdateAppStatusRequest) (*proto1.UpdateAppStatusResponse, error)

type DRPCAgentSocketUnimplementedServer

+ func (s *DRPCAgentSocketUnimplementedServer) UpdateAppStatus(context.Context, *proto1.UpdateAppStatusRequest) (*proto1.UpdateAppStatusResponse, error)

+ type DRPCAgentSocket_UpdateAppStatusStream interface

+ SendAndClose func(*proto1.UpdateAppStatusResponse) error

Dec 2, 2025

Changes in this version

+ const CurrentMajor

+ const CurrentMinor

+ var CurrentVersion = apiversion.New(CurrentMajor, CurrentMinor)

+ var File_agent_agentsocket_proto_agentsocket_proto protoreflect.FileDescriptor

+ func DRPCRegisterAgentSocket(mux drpc.Mux, impl DRPCAgentSocketServer) error

+ type DRPCAgentSocketClient interface

+ DRPCConn func() drpc.Conn

+ Ping func(ctx context.Context, in *PingRequest) (*PingResponse, error)

+ SyncComplete func(ctx context.Context, in *SyncCompleteRequest) (*SyncCompleteResponse, error)

+ SyncReady func(ctx context.Context, in *SyncReadyRequest) (*SyncReadyResponse, error)

+ SyncStart func(ctx context.Context, in *SyncStartRequest) (*SyncStartResponse, error)

+ SyncStatus func(ctx context.Context, in *SyncStatusRequest) (*SyncStatusResponse, error)

+ SyncWant func(ctx context.Context, in *SyncWantRequest) (*SyncWantResponse, error)

+ func NewDRPCAgentSocketClient(cc drpc.Conn) DRPCAgentSocketClient

+ type DRPCAgentSocketDescription struct

+ func (DRPCAgentSocketDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

+ func (DRPCAgentSocketDescription) NumMethods() int

+ type DRPCAgentSocketServer interface

+ Ping func(context.Context, *PingRequest) (*PingResponse, error)

+ SyncComplete func(context.Context, *SyncCompleteRequest) (*SyncCompleteResponse, error)

+ SyncReady func(context.Context, *SyncReadyRequest) (*SyncReadyResponse, error)

+ SyncStart func(context.Context, *SyncStartRequest) (*SyncStartResponse, error)

+ SyncStatus func(context.Context, *SyncStatusRequest) (*SyncStatusResponse, error)

+ SyncWant func(context.Context, *SyncWantRequest) (*SyncWantResponse, error)

+ type DRPCAgentSocketUnimplementedServer struct

+ func (s *DRPCAgentSocketUnimplementedServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

+ func (s *DRPCAgentSocketUnimplementedServer) SyncComplete(context.Context, *SyncCompleteRequest) (*SyncCompleteResponse, error)

+ func (s *DRPCAgentSocketUnimplementedServer) SyncReady(context.Context, *SyncReadyRequest) (*SyncReadyResponse, error)

+ func (s *DRPCAgentSocketUnimplementedServer) SyncStart(context.Context, *SyncStartRequest) (*SyncStartResponse, error)

+ func (s *DRPCAgentSocketUnimplementedServer) SyncStatus(context.Context, *SyncStatusRequest) (*SyncStatusResponse, error)

+ func (s *DRPCAgentSocketUnimplementedServer) SyncWant(context.Context, *SyncWantRequest) (*SyncWantResponse, error)

+ type DRPCAgentSocket_PingStream interface

+ SendAndClose func(*PingResponse) error

+ type DRPCAgentSocket_SyncCompleteStream interface

+ SendAndClose func(*SyncCompleteResponse) error

+ type DRPCAgentSocket_SyncReadyStream interface

+ SendAndClose func(*SyncReadyResponse) error

+ type DRPCAgentSocket_SyncStartStream interface

+ SendAndClose func(*SyncStartResponse) error

+ type DRPCAgentSocket_SyncStatusStream interface

+ SendAndClose func(*SyncStatusResponse) error

+ type DRPCAgentSocket_SyncWantStream interface

+ SendAndClose func(*SyncWantResponse) error

+ type DependencyInfo struct

+ CurrentStatus string

+ DependsOn string

+ IsSatisfied bool

+ RequiredStatus string

+ Unit string

+ func (*DependencyInfo) Descriptor() ([]byte, []int)

+ func (*DependencyInfo) ProtoMessage()

+ func (x *DependencyInfo) GetCurrentStatus() string

+ func (x *DependencyInfo) GetDependsOn() string

+ func (x *DependencyInfo) GetIsSatisfied() bool

+ func (x *DependencyInfo) GetRequiredStatus() string

+ func (x *DependencyInfo) GetUnit() string

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

+ func (x *DependencyInfo) Reset()

+ func (x *DependencyInfo) String() string

+ type PingRequest struct

+ func (*PingRequest) Descriptor() ([]byte, []int)

+ func (*PingRequest) ProtoMessage()

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

+ func (x *PingRequest) Reset()

+ func (x *PingRequest) String() string

+ type PingResponse struct

+ func (*PingResponse) Descriptor() ([]byte, []int)

+ func (*PingResponse) ProtoMessage()

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

+ func (x *PingResponse) Reset()

+ func (x *PingResponse) String() string

+ type SyncCompleteRequest struct

+ Unit string

+ func (*SyncCompleteRequest) Descriptor() ([]byte, []int)

+ func (*SyncCompleteRequest) ProtoMessage()

+ func (x *SyncCompleteRequest) GetUnit() string

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

+ func (x *SyncCompleteRequest) Reset()

+ func (x *SyncCompleteRequest) String() string

+ type SyncCompleteResponse struct

+ func (*SyncCompleteResponse) Descriptor() ([]byte, []int)

+ func (*SyncCompleteResponse) ProtoMessage()

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

+ func (x *SyncCompleteResponse) Reset()

+ func (x *SyncCompleteResponse) String() string

+ type SyncReadyRequest struct

+ Unit string

+ func (*SyncReadyRequest) Descriptor() ([]byte, []int)

+ func (*SyncReadyRequest) ProtoMessage()

+ func (x *SyncReadyRequest) GetUnit() string

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

+ func (x *SyncReadyRequest) Reset()

+ func (x *SyncReadyRequest) String() string

+ type SyncReadyResponse struct

+ Ready bool

+ func (*SyncReadyResponse) Descriptor() ([]byte, []int)

+ func (*SyncReadyResponse) ProtoMessage()

+ func (x *SyncReadyResponse) GetReady() bool

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

+ func (x *SyncReadyResponse) Reset()

+ func (x *SyncReadyResponse) String() string

+ type SyncStartRequest struct

+ Unit string

+ func (*SyncStartRequest) Descriptor() ([]byte, []int)

+ func (*SyncStartRequest) ProtoMessage()

+ func (x *SyncStartRequest) GetUnit() string

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

+ func (x *SyncStartRequest) Reset()

+ func (x *SyncStartRequest) String() string

+ type SyncStartResponse struct

+ func (*SyncStartResponse) Descriptor() ([]byte, []int)

+ func (*SyncStartResponse) ProtoMessage()

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

+ func (x *SyncStartResponse) Reset()

+ func (x *SyncStartResponse) String() string

+ type SyncStatusRequest struct

+ Unit string

+ func (*SyncStatusRequest) Descriptor() ([]byte, []int)

+ func (*SyncStatusRequest) ProtoMessage()

+ func (x *SyncStatusRequest) GetUnit() string

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

+ func (x *SyncStatusRequest) Reset()

+ func (x *SyncStatusRequest) String() string

+ type SyncStatusResponse struct

+ Dependencies []*DependencyInfo

+ IsReady bool

+ Status string

+ func (*SyncStatusResponse) Descriptor() ([]byte, []int)

+ func (*SyncStatusResponse) ProtoMessage()

+ func (x *SyncStatusResponse) GetDependencies() []*DependencyInfo

+ func (x *SyncStatusResponse) GetIsReady() bool

+ func (x *SyncStatusResponse) GetStatus() string

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

+ func (x *SyncStatusResponse) Reset()

+ func (x *SyncStatusResponse) String() string

+ type SyncWantRequest struct

+ DependsOn string

+ Unit string

+ func (*SyncWantRequest) Descriptor() ([]byte, []int)

+ func (*SyncWantRequest) ProtoMessage()

+ func (x *SyncWantRequest) GetDependsOn() string

+ func (x *SyncWantRequest) GetUnit() string

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

+ func (x *SyncWantRequest) Reset()

+ func (x *SyncWantRequest) String() string

+ type SyncWantResponse struct

+ func (*SyncWantResponse) Descriptor() ([]byte, []int)

+ func (*SyncWantResponse) ProtoMessage()

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

+ func (x *SyncWantResponse) Reset()

+ func (x *SyncWantResponse) String() string