proto

package
v2.29.1 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2025 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CurrentMajor = 1
	CurrentMinor = 0
)

Variables

View Source
var File_agent_agentsocket_proto_agentsocket_proto protoreflect.FileDescriptor

Functions

func DRPCRegisterAgentSocket

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

Types

type DRPCAgentSocketClient

type DRPCAgentSocketClient interface {
	DRPCConn() drpc.Conn

	Ping(ctx context.Context, in *PingRequest) (*PingResponse, error)
	SyncStart(ctx context.Context, in *SyncStartRequest) (*SyncStartResponse, error)
	SyncWant(ctx context.Context, in *SyncWantRequest) (*SyncWantResponse, error)
	SyncComplete(ctx context.Context, in *SyncCompleteRequest) (*SyncCompleteResponse, error)
	SyncReady(ctx context.Context, in *SyncReadyRequest) (*SyncReadyResponse, error)
	SyncStatus(ctx context.Context, in *SyncStatusRequest) (*SyncStatusResponse, error)
}

func NewDRPCAgentSocketClient

func NewDRPCAgentSocketClient(cc drpc.Conn) DRPCAgentSocketClient

type DRPCAgentSocketDescription

type DRPCAgentSocketDescription struct{}

func (DRPCAgentSocketDescription) Method

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

func (DRPCAgentSocketDescription) NumMethods

func (DRPCAgentSocketDescription) NumMethods() int

type DRPCAgentSocketUnimplementedServer

type DRPCAgentSocketUnimplementedServer struct{}

func (*DRPCAgentSocketUnimplementedServer) Ping

func (*DRPCAgentSocketUnimplementedServer) SyncComplete

func (*DRPCAgentSocketUnimplementedServer) SyncReady

func (*DRPCAgentSocketUnimplementedServer) SyncStart

func (*DRPCAgentSocketUnimplementedServer) SyncStatus

func (*DRPCAgentSocketUnimplementedServer) SyncWant

type DRPCAgentSocket_PingStream

type DRPCAgentSocket_PingStream interface {
	drpc.Stream
	SendAndClose(*PingResponse) error
}

type DRPCAgentSocket_SyncCompleteStream

type DRPCAgentSocket_SyncCompleteStream interface {
	drpc.Stream
	SendAndClose(*SyncCompleteResponse) error
}

type DRPCAgentSocket_SyncReadyStream

type DRPCAgentSocket_SyncReadyStream interface {
	drpc.Stream
	SendAndClose(*SyncReadyResponse) error
}

type DRPCAgentSocket_SyncStartStream

type DRPCAgentSocket_SyncStartStream interface {
	drpc.Stream
	SendAndClose(*SyncStartResponse) error
}

type DRPCAgentSocket_SyncStatusStream

type DRPCAgentSocket_SyncStatusStream interface {
	drpc.Stream
	SendAndClose(*SyncStatusResponse) error
}

type DRPCAgentSocket_SyncWantStream

type DRPCAgentSocket_SyncWantStream interface {
	drpc.Stream
	SendAndClose(*SyncWantResponse) error
}

type DependencyInfo

type DependencyInfo struct {
	Unit           string `protobuf:"bytes,1,opt,name=unit,proto3" json:"unit,omitempty"`
	DependsOn      string `protobuf:"bytes,2,opt,name=depends_on,json=dependsOn,proto3" json:"depends_on,omitempty"`
	RequiredStatus string `protobuf:"bytes,3,opt,name=required_status,json=requiredStatus,proto3" json:"required_status,omitempty"`
	CurrentStatus  string `protobuf:"bytes,4,opt,name=current_status,json=currentStatus,proto3" json:"current_status,omitempty"`
	IsSatisfied    bool   `protobuf:"varint,5,opt,name=is_satisfied,json=isSatisfied,proto3" json:"is_satisfied,omitempty"`
	// contains filtered or unexported fields
}

func (*DependencyInfo) Descriptor deprecated

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

Deprecated: Use DependencyInfo.ProtoReflect.Descriptor instead.

func (*DependencyInfo) GetCurrentStatus

func (x *DependencyInfo) GetCurrentStatus() string

func (*DependencyInfo) GetDependsOn

func (x *DependencyInfo) GetDependsOn() string

func (*DependencyInfo) GetIsSatisfied

func (x *DependencyInfo) GetIsSatisfied() bool

func (*DependencyInfo) GetRequiredStatus

func (x *DependencyInfo) GetRequiredStatus() string

func (*DependencyInfo) GetUnit

func (x *DependencyInfo) GetUnit() string

func (*DependencyInfo) ProtoMessage

func (*DependencyInfo) ProtoMessage()

func (*DependencyInfo) ProtoReflect

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

func (*DependencyInfo) Reset

func (x *DependencyInfo) Reset()

func (*DependencyInfo) String

func (x *DependencyInfo) String() string

type PingRequest

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

func (*PingRequest) Descriptor deprecated

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

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

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PingResponse

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

func (*PingResponse) Descriptor deprecated

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect

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

func (*PingResponse) Reset

func (x *PingResponse) Reset()

func (*PingResponse) String

func (x *PingResponse) String() string

type SyncCompleteRequest

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

func (*SyncCompleteRequest) Descriptor deprecated

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

Deprecated: Use SyncCompleteRequest.ProtoReflect.Descriptor instead.

func (*SyncCompleteRequest) GetUnit

func (x *SyncCompleteRequest) GetUnit() string

func (*SyncCompleteRequest) ProtoMessage

func (*SyncCompleteRequest) ProtoMessage()

func (*SyncCompleteRequest) ProtoReflect

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

func (*SyncCompleteRequest) Reset

func (x *SyncCompleteRequest) Reset()

func (*SyncCompleteRequest) String

func (x *SyncCompleteRequest) String() string

type SyncCompleteResponse

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

func (*SyncCompleteResponse) Descriptor deprecated

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

Deprecated: Use SyncCompleteResponse.ProtoReflect.Descriptor instead.

func (*SyncCompleteResponse) ProtoMessage

func (*SyncCompleteResponse) ProtoMessage()

func (*SyncCompleteResponse) ProtoReflect

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

func (*SyncCompleteResponse) Reset

func (x *SyncCompleteResponse) Reset()

func (*SyncCompleteResponse) String

func (x *SyncCompleteResponse) String() string

type SyncReadyRequest

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

func (*SyncReadyRequest) Descriptor deprecated

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

Deprecated: Use SyncReadyRequest.ProtoReflect.Descriptor instead.

func (*SyncReadyRequest) GetUnit

func (x *SyncReadyRequest) GetUnit() string

func (*SyncReadyRequest) ProtoMessage

func (*SyncReadyRequest) ProtoMessage()

func (*SyncReadyRequest) ProtoReflect

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

func (*SyncReadyRequest) Reset

func (x *SyncReadyRequest) Reset()

func (*SyncReadyRequest) String

func (x *SyncReadyRequest) String() string

type SyncReadyResponse

type SyncReadyResponse struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncReadyResponse) Descriptor deprecated

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

Deprecated: Use SyncReadyResponse.ProtoReflect.Descriptor instead.

func (*SyncReadyResponse) GetReady

func (x *SyncReadyResponse) GetReady() bool

func (*SyncReadyResponse) ProtoMessage

func (*SyncReadyResponse) ProtoMessage()

func (*SyncReadyResponse) ProtoReflect

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

func (*SyncReadyResponse) Reset

func (x *SyncReadyResponse) Reset()

func (*SyncReadyResponse) String

func (x *SyncReadyResponse) String() string

type SyncStartRequest

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

func (*SyncStartRequest) Descriptor deprecated

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

Deprecated: Use SyncStartRequest.ProtoReflect.Descriptor instead.

func (*SyncStartRequest) GetUnit

func (x *SyncStartRequest) GetUnit() string

func (*SyncStartRequest) ProtoMessage

func (*SyncStartRequest) ProtoMessage()

func (*SyncStartRequest) ProtoReflect

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

func (*SyncStartRequest) Reset

func (x *SyncStartRequest) Reset()

func (*SyncStartRequest) String

func (x *SyncStartRequest) String() string

type SyncStartResponse

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

func (*SyncStartResponse) Descriptor deprecated

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

Deprecated: Use SyncStartResponse.ProtoReflect.Descriptor instead.

func (*SyncStartResponse) ProtoMessage

func (*SyncStartResponse) ProtoMessage()

func (*SyncStartResponse) ProtoReflect

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

func (*SyncStartResponse) Reset

func (x *SyncStartResponse) Reset()

func (*SyncStartResponse) String

func (x *SyncStartResponse) String() string

type SyncStatusRequest

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

func (*SyncStatusRequest) Descriptor deprecated

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

Deprecated: Use SyncStatusRequest.ProtoReflect.Descriptor instead.

func (*SyncStatusRequest) GetUnit

func (x *SyncStatusRequest) GetUnit() string

func (*SyncStatusRequest) ProtoMessage

func (*SyncStatusRequest) ProtoMessage()

func (*SyncStatusRequest) ProtoReflect

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

func (*SyncStatusRequest) Reset

func (x *SyncStatusRequest) Reset()

func (*SyncStatusRequest) String

func (x *SyncStatusRequest) String() string

type SyncStatusResponse

type SyncStatusResponse struct {
	Status       string            `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IsReady      bool              `protobuf:"varint,2,opt,name=is_ready,json=isReady,proto3" json:"is_ready,omitempty"`
	Dependencies []*DependencyInfo `protobuf:"bytes,3,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncStatusResponse) Descriptor deprecated

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

Deprecated: Use SyncStatusResponse.ProtoReflect.Descriptor instead.

func (*SyncStatusResponse) GetDependencies

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

func (*SyncStatusResponse) GetIsReady

func (x *SyncStatusResponse) GetIsReady() bool

func (*SyncStatusResponse) GetStatus

func (x *SyncStatusResponse) GetStatus() string

func (*SyncStatusResponse) ProtoMessage

func (*SyncStatusResponse) ProtoMessage()

func (*SyncStatusResponse) ProtoReflect

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

func (*SyncStatusResponse) Reset

func (x *SyncStatusResponse) Reset()

func (*SyncStatusResponse) String

func (x *SyncStatusResponse) String() string

type SyncWantRequest

type SyncWantRequest struct {
	Unit      string `protobuf:"bytes,1,opt,name=unit,proto3" json:"unit,omitempty"`
	DependsOn string `protobuf:"bytes,2,opt,name=depends_on,json=dependsOn,proto3" json:"depends_on,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncWantRequest) Descriptor deprecated

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

Deprecated: Use SyncWantRequest.ProtoReflect.Descriptor instead.

func (*SyncWantRequest) GetDependsOn

func (x *SyncWantRequest) GetDependsOn() string

func (*SyncWantRequest) GetUnit

func (x *SyncWantRequest) GetUnit() string

func (*SyncWantRequest) ProtoMessage

func (*SyncWantRequest) ProtoMessage()

func (*SyncWantRequest) ProtoReflect

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

func (*SyncWantRequest) Reset

func (x *SyncWantRequest) Reset()

func (*SyncWantRequest) String

func (x *SyncWantRequest) String() string

type SyncWantResponse

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

func (*SyncWantResponse) Descriptor deprecated

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

Deprecated: Use SyncWantResponse.ProtoReflect.Descriptor instead.

func (*SyncWantResponse) ProtoMessage

func (*SyncWantResponse) ProtoMessage()

func (*SyncWantResponse) ProtoReflect

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

func (*SyncWantResponse) Reset

func (x *SyncWantResponse) Reset()

func (*SyncWantResponse) String

func (x *SyncWantResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL