Documentation
¶
Index ¶
- Constants
- Variables
- func DRPCRegisterAgentSocket(mux drpc.Mux, impl DRPCAgentSocketServer) error
- type DRPCAgentSocketClient
- type DRPCAgentSocketDescription
- type DRPCAgentSocketServer
- type DRPCAgentSocketUnimplementedServer
- 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
- type DRPCAgentSocket_SyncCompleteStream
- type DRPCAgentSocket_SyncReadyStream
- type DRPCAgentSocket_SyncStartStream
- type DRPCAgentSocket_SyncStatusStream
- type DRPCAgentSocket_SyncWantStream
- type DependencyInfo
- func (*DependencyInfo) Descriptor() ([]byte, []int)deprecated
- 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 (*DependencyInfo) ProtoMessage()
- func (x *DependencyInfo) ProtoReflect() protoreflect.Message
- func (x *DependencyInfo) Reset()
- func (x *DependencyInfo) String() string
- type PingRequest
- type PingResponse
- type SyncCompleteRequest
- func (*SyncCompleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncCompleteRequest) GetUnit() string
- func (*SyncCompleteRequest) ProtoMessage()
- func (x *SyncCompleteRequest) ProtoReflect() protoreflect.Message
- func (x *SyncCompleteRequest) Reset()
- func (x *SyncCompleteRequest) String() string
- type SyncCompleteResponse
- type SyncReadyRequest
- type SyncReadyResponse
- type SyncStartRequest
- type SyncStartResponse
- type SyncStatusRequest
- type SyncStatusResponse
- func (*SyncStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncStatusResponse) GetDependencies() []*DependencyInfo
- func (x *SyncStatusResponse) GetIsReady() bool
- func (x *SyncStatusResponse) GetStatus() string
- func (*SyncStatusResponse) ProtoMessage()
- func (x *SyncStatusResponse) ProtoReflect() protoreflect.Message
- func (x *SyncStatusResponse) Reset()
- func (x *SyncStatusResponse) String() string
- type SyncWantRequest
- func (*SyncWantRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncWantRequest) GetDependsOn() string
- func (x *SyncWantRequest) GetUnit() string
- func (*SyncWantRequest) ProtoMessage()
- func (x *SyncWantRequest) ProtoReflect() protoreflect.Message
- func (x *SyncWantRequest) Reset()
- func (x *SyncWantRequest) String() string
- type SyncWantResponse
Constants ¶
const ( CurrentMajor = 1 CurrentMinor = 0 )
Variables ¶
var CurrentVersion = apiversion.New(CurrentMajor, CurrentMinor)
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) NumMethods ¶
func (DRPCAgentSocketDescription) NumMethods() int
type DRPCAgentSocketServer ¶
type DRPCAgentSocketServer interface {
Ping(context.Context, *PingRequest) (*PingResponse, error)
SyncStart(context.Context, *SyncStartRequest) (*SyncStartResponse, error)
SyncWant(context.Context, *SyncWantRequest) (*SyncWantResponse, error)
SyncComplete(context.Context, *SyncCompleteRequest) (*SyncCompleteResponse, error)
SyncReady(context.Context, *SyncReadyRequest) (*SyncReadyResponse, error)
SyncStatus(context.Context, *SyncStatusRequest) (*SyncStatusResponse, error)
}
type DRPCAgentSocketUnimplementedServer ¶
type DRPCAgentSocketUnimplementedServer struct{}
func (*DRPCAgentSocketUnimplementedServer) Ping ¶
func (s *DRPCAgentSocketUnimplementedServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
func (*DRPCAgentSocketUnimplementedServer) SyncComplete ¶
func (s *DRPCAgentSocketUnimplementedServer) SyncComplete(context.Context, *SyncCompleteRequest) (*SyncCompleteResponse, error)
func (*DRPCAgentSocketUnimplementedServer) SyncReady ¶
func (s *DRPCAgentSocketUnimplementedServer) SyncReady(context.Context, *SyncReadyRequest) (*SyncReadyResponse, error)
func (*DRPCAgentSocketUnimplementedServer) SyncStart ¶
func (s *DRPCAgentSocketUnimplementedServer) SyncStart(context.Context, *SyncStartRequest) (*SyncStartResponse, error)
func (*DRPCAgentSocketUnimplementedServer) SyncStatus ¶
func (s *DRPCAgentSocketUnimplementedServer) SyncStatus(context.Context, *SyncStatusRequest) (*SyncStatusResponse, error)
func (*DRPCAgentSocketUnimplementedServer) SyncWant ¶
func (s *DRPCAgentSocketUnimplementedServer) SyncWant(context.Context, *SyncWantRequest) (*SyncWantResponse, error)
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