Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterMigrationServiceServer(s grpc.ServiceRegistrar, srv MigrationServiceServer)
- type AgentMessage
- func (*AgentMessage) Descriptor() ([]byte, []int)deprecated
- func (x *AgentMessage) GetDenied() *Denied
- func (x *AgentMessage) GetHeartbeat() *Heartbeat
- func (x *AgentMessage) GetHello() *Hello
- func (x *AgentMessage) GetInventory() *Inventory
- func (x *AgentMessage) GetPayload() isAgentMessage_Payload
- func (x *AgentMessage) GetScanResult() *ScanResult
- func (*AgentMessage) ProtoMessage()
- func (x *AgentMessage) ProtoReflect() protoreflect.Message
- func (x *AgentMessage) Reset()
- func (x *AgentMessage) String() string
- type AgentMessage_Denied
- type AgentMessage_Heartbeat
- type AgentMessage_Hello
- type AgentMessage_Inventory
- type AgentMessage_ScanResult
- type Container
- func (*Container) Descriptor() ([]byte, []int)deprecated
- func (x *Container) GetDatabaseEngine() string
- func (x *Container) GetDatabaseVersion() string
- func (x *Container) GetEnvKeys() []string
- func (x *Container) GetId() string
- func (x *Container) GetImage() string
- func (x *Container) GetMounts() []*Mount
- func (x *Container) GetName() string
- func (x *Container) GetPorts() []string
- func (x *Container) GetState() string
- func (x *Container) GetStatus() string
- func (*Container) ProtoMessage()
- func (x *Container) ProtoReflect() protoreflect.Message
- func (x *Container) Reset()
- func (x *Container) String() string
- type ControlMessage
- func (*ControlMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ControlMessage) GetDiscover() *DiscoverRequest
- func (x *ControlMessage) GetGoAway() *GoAway
- func (x *ControlMessage) GetPayload() isControlMessage_Payload
- func (x *ControlMessage) GetScan() *ScanRequest
- func (*ControlMessage) ProtoMessage()
- func (x *ControlMessage) ProtoReflect() protoreflect.Message
- func (x *ControlMessage) Reset()
- func (x *ControlMessage) String() string
- type ControlMessage_Discover
- type ControlMessage_GoAway
- type ControlMessage_Scan
- type Denied
- type DiscoverRequest
- type EnrollRequest
- func (*EnrollRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EnrollRequest) GetArch() string
- func (x *EnrollRequest) GetCaPinState() string
- func (x *EnrollRequest) GetCsrDer() []byte
- func (x *EnrollRequest) GetJoinToken() string
- func (x *EnrollRequest) GetOs() string
- func (x *EnrollRequest) GetVersion() string
- func (*EnrollRequest) ProtoMessage()
- func (x *EnrollRequest) ProtoReflect() protoreflect.Message
- func (x *EnrollRequest) Reset()
- func (x *EnrollRequest) String() string
- type EnrollResponse
- func (*EnrollResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EnrollResponse) GetCaCertPem() []byte
- func (x *EnrollResponse) GetClientCertPem() []byte
- func (x *EnrollResponse) GetNotAfter() *timestamppb.Timestamp
- func (x *EnrollResponse) GetSessionExpiresAt() *timestamppb.Timestamp
- func (x *EnrollResponse) GetSessionId() string
- func (*EnrollResponse) ProtoMessage()
- func (x *EnrollResponse) ProtoReflect() protoreflect.Message
- func (x *EnrollResponse) Reset()
- func (x *EnrollResponse) String() string
- type GoAway
- type Heartbeat
- type Hello
- type Inventory
- func (*Inventory) Descriptor() ([]byte, []int)deprecated
- func (x *Inventory) GetCollectedAt() *timestamppb.Timestamp
- func (x *Inventory) GetContainers() []*Container
- func (x *Inventory) GetDockerVersion() string
- func (x *Inventory) GetNetworkCount() int32
- func (x *Inventory) GetRequestId() string
- func (x *Inventory) GetVolumes() []*Volume
- func (*Inventory) ProtoMessage()
- func (x *Inventory) ProtoReflect() protoreflect.Message
- func (x *Inventory) Reset()
- func (x *Inventory) String() string
- type MigrationServiceClient
- type MigrationServiceServer
- type MigrationService_SessionClient
- type MigrationService_SessionServer
- type Mount
- func (*Mount) Descriptor() ([]byte, []int)deprecated
- func (x *Mount) GetDestination() string
- func (x *Mount) GetName() string
- func (x *Mount) GetReadOnly() bool
- func (x *Mount) GetSource() string
- func (x *Mount) GetType() string
- func (*Mount) ProtoMessage()
- func (x *Mount) ProtoReflect() protoreflect.Message
- func (x *Mount) Reset()
- func (x *Mount) String() string
- type ScanRequest
- func (*ScanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ScanRequest) GetRequestId() string
- func (x *ScanRequest) GetTargets() []string
- func (*ScanRequest) ProtoMessage()
- func (x *ScanRequest) ProtoReflect() protoreflect.Message
- func (x *ScanRequest) Reset()
- func (x *ScanRequest) String() string
- type ScanResult
- func (*ScanResult) Descriptor() ([]byte, []int)deprecated
- func (x *ScanResult) GetRequestId() string
- func (x *ScanResult) GetStats() []*VolumeStat
- func (*ScanResult) ProtoMessage()
- func (x *ScanResult) ProtoReflect() protoreflect.Message
- func (x *ScanResult) Reset()
- func (x *ScanResult) String() string
- type UnimplementedMigrationServiceServer
- type UnsafeMigrationServiceServer
- type Volume
- func (*Volume) Descriptor() ([]byte, []int)deprecated
- func (x *Volume) GetDriver() string
- func (x *Volume) GetMountpoint() string
- func (x *Volume) GetName() string
- func (*Volume) ProtoMessage()
- func (x *Volume) ProtoReflect() protoreflect.Message
- func (x *Volume) Reset()
- func (x *Volume) String() string
- type VolumeStat
- func (*VolumeStat) Descriptor() ([]byte, []int)deprecated
- func (x *VolumeStat) GetBytes() int64
- func (x *VolumeStat) GetChangedDuringScan() bool
- func (x *VolumeStat) GetError() string
- func (x *VolumeStat) GetFiles() int64
- func (x *VolumeStat) GetTarget() string
- func (*VolumeStat) ProtoMessage()
- func (x *VolumeStat) ProtoReflect() protoreflect.Message
- func (x *VolumeStat) Reset()
- func (x *VolumeStat) String() string
Constants ¶
const ( MigrationService_Enroll_FullMethodName = "/levelrail.migration.v1.MigrationService/Enroll" MigrationService_Session_FullMethodName = "/levelrail.migration.v1.MigrationService/Session" )
Variables ¶
var File_proto_agent_v1_migration_proto protoreflect.FileDescriptor
var MigrationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "levelrail.migration.v1.MigrationService", HandlerType: (*MigrationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Enroll", Handler: _MigrationService_Enroll_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Session", Handler: _MigrationService_Session_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "proto/agent/v1/migration.proto", }
MigrationService_ServiceDesc is the grpc.ServiceDesc for MigrationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMigrationServiceServer ¶
func RegisterMigrationServiceServer(s grpc.ServiceRegistrar, srv MigrationServiceServer)
Types ¶
type AgentMessage ¶
type AgentMessage struct {
// Types that are valid to be assigned to Payload:
//
// *AgentMessage_Hello
// *AgentMessage_Heartbeat
// *AgentMessage_Inventory
// *AgentMessage_ScanResult
// *AgentMessage_Denied
Payload isAgentMessage_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*AgentMessage) Descriptor
deprecated
func (*AgentMessage) Descriptor() ([]byte, []int)
Deprecated: Use AgentMessage.ProtoReflect.Descriptor instead.
func (*AgentMessage) GetDenied ¶
func (x *AgentMessage) GetDenied() *Denied
func (*AgentMessage) GetHeartbeat ¶
func (x *AgentMessage) GetHeartbeat() *Heartbeat
func (*AgentMessage) GetHello ¶
func (x *AgentMessage) GetHello() *Hello
func (*AgentMessage) GetInventory ¶
func (x *AgentMessage) GetInventory() *Inventory
func (*AgentMessage) GetPayload ¶
func (x *AgentMessage) GetPayload() isAgentMessage_Payload
func (*AgentMessage) GetScanResult ¶
func (x *AgentMessage) GetScanResult() *ScanResult
func (*AgentMessage) ProtoMessage ¶
func (*AgentMessage) ProtoMessage()
func (*AgentMessage) ProtoReflect ¶
func (x *AgentMessage) ProtoReflect() protoreflect.Message
func (*AgentMessage) Reset ¶
func (x *AgentMessage) Reset()
func (*AgentMessage) String ¶
func (x *AgentMessage) String() string
type AgentMessage_Denied ¶
type AgentMessage_Denied struct {
Denied *Denied `protobuf:"bytes,5,opt,name=denied,proto3,oneof"`
}
type AgentMessage_Heartbeat ¶
type AgentMessage_Heartbeat struct {
Heartbeat *Heartbeat `protobuf:"bytes,2,opt,name=heartbeat,proto3,oneof"`
}
type AgentMessage_Hello ¶
type AgentMessage_Hello struct {
Hello *Hello `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}
type AgentMessage_Inventory ¶
type AgentMessage_Inventory struct {
Inventory *Inventory `protobuf:"bytes,3,opt,name=inventory,proto3,oneof"`
}
type AgentMessage_ScanResult ¶
type AgentMessage_ScanResult struct {
ScanResult *ScanResult `protobuf:"bytes,4,opt,name=scan_result,json=scanResult,proto3,oneof"`
}
type Container ¶
type Container struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
// env_keys are variable names only. Values never leave the host.
EnvKeys []string `protobuf:"bytes,6,rep,name=env_keys,json=envKeys,proto3" json:"env_keys,omitempty"`
Mounts []*Mount `protobuf:"bytes,7,rep,name=mounts,proto3" json:"mounts,omitempty"`
Ports []string `protobuf:"bytes,8,rep,name=ports,proto3" json:"ports,omitempty"`
// database_engine is set when the image looks like a database server.
DatabaseEngine string `protobuf:"bytes,9,opt,name=database_engine,json=databaseEngine,proto3" json:"database_engine,omitempty"`
DatabaseVersion string `protobuf:"bytes,10,opt,name=database_version,json=databaseVersion,proto3" json:"database_version,omitempty"`
// contains filtered or unexported fields
}
func (*Container) Descriptor
deprecated
func (*Container) GetDatabaseEngine ¶
func (*Container) GetDatabaseVersion ¶
func (*Container) GetEnvKeys ¶
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
func (*Container) ProtoReflect ¶
func (x *Container) ProtoReflect() protoreflect.Message
type ControlMessage ¶
type ControlMessage struct {
// Types that are valid to be assigned to Payload:
//
// *ControlMessage_Discover
// *ControlMessage_Scan
// *ControlMessage_GoAway
Payload isControlMessage_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
ControlMessage is the whole migration request set. Anything else the agent receives is a protocol violation and ends the session.
func (*ControlMessage) Descriptor
deprecated
func (*ControlMessage) Descriptor() ([]byte, []int)
Deprecated: Use ControlMessage.ProtoReflect.Descriptor instead.
func (*ControlMessage) GetDiscover ¶
func (x *ControlMessage) GetDiscover() *DiscoverRequest
func (*ControlMessage) GetGoAway ¶
func (x *ControlMessage) GetGoAway() *GoAway
func (*ControlMessage) GetPayload ¶
func (x *ControlMessage) GetPayload() isControlMessage_Payload
func (*ControlMessage) GetScan ¶
func (x *ControlMessage) GetScan() *ScanRequest
func (*ControlMessage) ProtoMessage ¶
func (*ControlMessage) ProtoMessage()
func (*ControlMessage) ProtoReflect ¶
func (x *ControlMessage) ProtoReflect() protoreflect.Message
func (*ControlMessage) Reset ¶
func (x *ControlMessage) Reset()
func (*ControlMessage) String ¶
func (x *ControlMessage) String() string
type ControlMessage_Discover ¶
type ControlMessage_Discover struct {
Discover *DiscoverRequest `protobuf:"bytes,1,opt,name=discover,proto3,oneof"`
}
type ControlMessage_GoAway ¶
type ControlMessage_GoAway struct {
GoAway *GoAway `protobuf:"bytes,3,opt,name=go_away,json=goAway,proto3,oneof"`
}
type ControlMessage_Scan ¶
type ControlMessage_Scan struct {
Scan *ScanRequest `protobuf:"bytes,2,opt,name=scan,proto3,oneof"`
}
type Denied ¶
type Denied struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
func (*Denied) Descriptor
deprecated
func (*Denied) GetRequestId ¶
func (*Denied) ProtoMessage ¶
func (*Denied) ProtoMessage()
func (*Denied) ProtoReflect ¶
func (x *Denied) ProtoReflect() protoreflect.Message
type DiscoverRequest ¶
type DiscoverRequest struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*DiscoverRequest) Descriptor
deprecated
func (*DiscoverRequest) Descriptor() ([]byte, []int)
Deprecated: Use DiscoverRequest.ProtoReflect.Descriptor instead.
func (*DiscoverRequest) GetRequestId ¶
func (x *DiscoverRequest) GetRequestId() string
func (*DiscoverRequest) ProtoMessage ¶
func (*DiscoverRequest) ProtoMessage()
func (*DiscoverRequest) ProtoReflect ¶
func (x *DiscoverRequest) ProtoReflect() protoreflect.Message
func (*DiscoverRequest) Reset ¶
func (x *DiscoverRequest) Reset()
func (*DiscoverRequest) String ¶
func (x *DiscoverRequest) String() string
type EnrollRequest ¶
type EnrollRequest struct {
JoinToken string `protobuf:"bytes,1,opt,name=join_token,json=joinToken,proto3" json:"join_token,omitempty"`
CsrDer []byte `protobuf:"bytes,2,opt,name=csr_der,json=csrDer,proto3" json:"csr_der,omitempty"`
Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
Os string `protobuf:"bytes,4,opt,name=os,proto3" json:"os,omitempty"`
Arch string `protobuf:"bytes,5,opt,name=arch,proto3" json:"arch,omitempty"`
// ca_pin_state is "pinned" when the agent verified the control plane CA
// against the fingerprint in the install command.
CaPinState string `protobuf:"bytes,6,opt,name=ca_pin_state,json=caPinState,proto3" json:"ca_pin_state,omitempty"`
// contains filtered or unexported fields
}
func (*EnrollRequest) Descriptor
deprecated
func (*EnrollRequest) Descriptor() ([]byte, []int)
Deprecated: Use EnrollRequest.ProtoReflect.Descriptor instead.
func (*EnrollRequest) GetArch ¶
func (x *EnrollRequest) GetArch() string
func (*EnrollRequest) GetCaPinState ¶
func (x *EnrollRequest) GetCaPinState() string
func (*EnrollRequest) GetCsrDer ¶
func (x *EnrollRequest) GetCsrDer() []byte
func (*EnrollRequest) GetJoinToken ¶
func (x *EnrollRequest) GetJoinToken() string
func (*EnrollRequest) GetOs ¶
func (x *EnrollRequest) GetOs() string
func (*EnrollRequest) GetVersion ¶
func (x *EnrollRequest) GetVersion() string
func (*EnrollRequest) ProtoMessage ¶
func (*EnrollRequest) ProtoMessage()
func (*EnrollRequest) ProtoReflect ¶
func (x *EnrollRequest) ProtoReflect() protoreflect.Message
func (*EnrollRequest) Reset ¶
func (x *EnrollRequest) Reset()
func (*EnrollRequest) String ¶
func (x *EnrollRequest) String() string
type EnrollResponse ¶
type EnrollResponse struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
ClientCertPem []byte `protobuf:"bytes,2,opt,name=client_cert_pem,json=clientCertPem,proto3" json:"client_cert_pem,omitempty"`
CaCertPem []byte `protobuf:"bytes,3,opt,name=ca_cert_pem,json=caCertPem,proto3" json:"ca_cert_pem,omitempty"`
NotAfter *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=not_after,json=notAfter,proto3" json:"not_after,omitempty"`
SessionExpiresAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=session_expires_at,json=sessionExpiresAt,proto3" json:"session_expires_at,omitempty"`
// contains filtered or unexported fields
}
func (*EnrollResponse) Descriptor
deprecated
func (*EnrollResponse) Descriptor() ([]byte, []int)
Deprecated: Use EnrollResponse.ProtoReflect.Descriptor instead.
func (*EnrollResponse) GetCaCertPem ¶
func (x *EnrollResponse) GetCaCertPem() []byte
func (*EnrollResponse) GetClientCertPem ¶
func (x *EnrollResponse) GetClientCertPem() []byte
func (*EnrollResponse) GetNotAfter ¶
func (x *EnrollResponse) GetNotAfter() *timestamppb.Timestamp
func (*EnrollResponse) GetSessionExpiresAt ¶
func (x *EnrollResponse) GetSessionExpiresAt() *timestamppb.Timestamp
func (*EnrollResponse) GetSessionId ¶
func (x *EnrollResponse) GetSessionId() string
func (*EnrollResponse) ProtoMessage ¶
func (*EnrollResponse) ProtoMessage()
func (*EnrollResponse) ProtoReflect ¶
func (x *EnrollResponse) ProtoReflect() protoreflect.Message
func (*EnrollResponse) Reset ¶
func (x *EnrollResponse) Reset()
func (*EnrollResponse) String ¶
func (x *EnrollResponse) String() string
type GoAway ¶
type GoAway struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
func (*GoAway) Descriptor
deprecated
func (*GoAway) ProtoMessage ¶
func (*GoAway) ProtoMessage()
func (*GoAway) ProtoReflect ¶
func (x *GoAway) ProtoReflect() protoreflect.Message
type Heartbeat ¶
type Heartbeat struct {
// contains filtered or unexported fields
}
func (*Heartbeat) Descriptor
deprecated
func (*Heartbeat) ProtoMessage ¶
func (*Heartbeat) ProtoMessage()
func (*Heartbeat) ProtoReflect ¶
func (x *Heartbeat) ProtoReflect() protoreflect.Message
type Hello ¶
type Hello struct {
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
Os string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
Arch string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"`
// contains filtered or unexported fields
}
func (*Hello) Descriptor
deprecated
func (*Hello) GetVersion ¶
func (*Hello) ProtoMessage ¶
func (*Hello) ProtoMessage()
func (*Hello) ProtoReflect ¶
func (x *Hello) ProtoReflect() protoreflect.Message
type Inventory ¶
type Inventory struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
DockerVersion string `protobuf:"bytes,2,opt,name=docker_version,json=dockerVersion,proto3" json:"docker_version,omitempty"`
Containers []*Container `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"`
Volumes []*Volume `protobuf:"bytes,4,rep,name=volumes,proto3" json:"volumes,omitempty"`
NetworkCount int32 `protobuf:"varint,5,opt,name=network_count,json=networkCount,proto3" json:"network_count,omitempty"`
CollectedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=collected_at,json=collectedAt,proto3" json:"collected_at,omitempty"`
// contains filtered or unexported fields
}
func (*Inventory) Descriptor
deprecated
func (*Inventory) GetCollectedAt ¶
func (x *Inventory) GetCollectedAt() *timestamppb.Timestamp
func (*Inventory) GetContainers ¶
func (*Inventory) GetDockerVersion ¶
func (*Inventory) GetNetworkCount ¶
func (*Inventory) GetRequestId ¶
func (*Inventory) GetVolumes ¶
func (*Inventory) ProtoMessage ¶
func (*Inventory) ProtoMessage()
func (*Inventory) ProtoReflect ¶
func (x *Inventory) ProtoReflect() protoreflect.Message
type MigrationServiceClient ¶
type MigrationServiceClient interface {
// Enroll exchanges a single-use migration token for a short-lived client
// certificate. The private key never leaves the source host.
Enroll(ctx context.Context, in *EnrollRequest, opts ...grpc.CallOption) (*EnrollResponse, error)
// Session is the long-lived mTLS stream the source dials out on.
Session(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AgentMessage, ControlMessage], error)
}
MigrationServiceClient is the client API for MigrationService 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.
func NewMigrationServiceClient ¶
func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient
type MigrationServiceServer ¶
type MigrationServiceServer interface {
// Enroll exchanges a single-use migration token for a short-lived client
// certificate. The private key never leaves the source host.
Enroll(context.Context, *EnrollRequest) (*EnrollResponse, error)
// Session is the long-lived mTLS stream the source dials out on.
Session(grpc.BidiStreamingServer[AgentMessage, ControlMessage]) error
// contains filtered or unexported methods
}
MigrationServiceServer is the server API for MigrationService service. All implementations must embed UnimplementedMigrationServiceServer for forward compatibility.
type MigrationService_SessionClient ¶
type MigrationService_SessionClient = grpc.BidiStreamingClient[AgentMessage, ControlMessage]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type MigrationService_SessionServer ¶
type MigrationService_SessionServer = grpc.BidiStreamingServer[AgentMessage, ControlMessage]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Mount ¶
type Mount struct {
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
Destination string `protobuf:"bytes,4,opt,name=destination,proto3" json:"destination,omitempty"`
ReadOnly bool `protobuf:"varint,5,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
// contains filtered or unexported fields
}
func (*Mount) Descriptor
deprecated
func (*Mount) GetDestination ¶
func (*Mount) GetReadOnly ¶
func (*Mount) ProtoMessage ¶
func (*Mount) ProtoMessage()
func (*Mount) ProtoReflect ¶
func (x *Mount) ProtoReflect() protoreflect.Message
type ScanRequest ¶
type ScanRequest struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
Targets []string `protobuf:"bytes,2,rep,name=targets,proto3" json:"targets,omitempty"`
// contains filtered or unexported fields
}
ScanRequest names volumes or bind mount paths that the latest inventory listed. The agent refuses any target it did not itself report.
func (*ScanRequest) Descriptor
deprecated
func (*ScanRequest) Descriptor() ([]byte, []int)
Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.
func (*ScanRequest) GetRequestId ¶
func (x *ScanRequest) GetRequestId() string
func (*ScanRequest) GetTargets ¶
func (x *ScanRequest) GetTargets() []string
func (*ScanRequest) ProtoMessage ¶
func (*ScanRequest) ProtoMessage()
func (*ScanRequest) ProtoReflect ¶
func (x *ScanRequest) ProtoReflect() protoreflect.Message
func (*ScanRequest) Reset ¶
func (x *ScanRequest) Reset()
func (*ScanRequest) String ¶
func (x *ScanRequest) String() string
type ScanResult ¶
type ScanResult struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
Stats []*VolumeStat `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
// contains filtered or unexported fields
}
func (*ScanResult) Descriptor
deprecated
func (*ScanResult) Descriptor() ([]byte, []int)
Deprecated: Use ScanResult.ProtoReflect.Descriptor instead.
func (*ScanResult) GetRequestId ¶
func (x *ScanResult) GetRequestId() string
func (*ScanResult) GetStats ¶
func (x *ScanResult) GetStats() []*VolumeStat
func (*ScanResult) ProtoMessage ¶
func (*ScanResult) ProtoMessage()
func (*ScanResult) ProtoReflect ¶
func (x *ScanResult) ProtoReflect() protoreflect.Message
func (*ScanResult) Reset ¶
func (x *ScanResult) Reset()
func (*ScanResult) String ¶
func (x *ScanResult) String() string
type UnimplementedMigrationServiceServer ¶
type UnimplementedMigrationServiceServer struct{}
UnimplementedMigrationServiceServer 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 (UnimplementedMigrationServiceServer) Enroll ¶
func (UnimplementedMigrationServiceServer) Enroll(context.Context, *EnrollRequest) (*EnrollResponse, error)
func (UnimplementedMigrationServiceServer) Session ¶
func (UnimplementedMigrationServiceServer) Session(grpc.BidiStreamingServer[AgentMessage, ControlMessage]) error
type UnsafeMigrationServiceServer ¶
type UnsafeMigrationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMigrationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MigrationServiceServer will result in compilation errors.
type Volume ¶
type Volume struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Driver string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
Mountpoint string `protobuf:"bytes,3,opt,name=mountpoint,proto3" json:"mountpoint,omitempty"`
// contains filtered or unexported fields
}
func (*Volume) Descriptor
deprecated
func (*Volume) GetMountpoint ¶
func (*Volume) ProtoMessage ¶
func (*Volume) ProtoMessage()
func (*Volume) ProtoReflect ¶
func (x *Volume) ProtoReflect() protoreflect.Message
type VolumeStat ¶
type VolumeStat struct {
Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
Files int64 `protobuf:"varint,2,opt,name=files,proto3" json:"files,omitempty"`
Bytes int64 `protobuf:"varint,3,opt,name=bytes,proto3" json:"bytes,omitempty"`
// changed_during_scan is true when a second pass saw different totals.
ChangedDuringScan bool `protobuf:"varint,4,opt,name=changed_during_scan,json=changedDuringScan,proto3" json:"changed_during_scan,omitempty"`
Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*VolumeStat) Descriptor
deprecated
func (*VolumeStat) Descriptor() ([]byte, []int)
Deprecated: Use VolumeStat.ProtoReflect.Descriptor instead.
func (*VolumeStat) GetBytes ¶
func (x *VolumeStat) GetBytes() int64
func (*VolumeStat) GetChangedDuringScan ¶
func (x *VolumeStat) GetChangedDuringScan() bool
func (*VolumeStat) GetError ¶
func (x *VolumeStat) GetError() string
func (*VolumeStat) GetFiles ¶
func (x *VolumeStat) GetFiles() int64
func (*VolumeStat) GetTarget ¶
func (x *VolumeStat) GetTarget() string
func (*VolumeStat) ProtoMessage ¶
func (*VolumeStat) ProtoMessage()
func (*VolumeStat) ProtoReflect ¶
func (x *VolumeStat) ProtoReflect() protoreflect.Message
func (*VolumeStat) Reset ¶
func (x *VolumeStat) Reset()
func (*VolumeStat) String ¶
func (x *VolumeStat) String() string