Documentation ¶
Index ¶
- Variables
- type DeleteFileRequest
- type DeleteFileResponse
- func (*DeleteFileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteFileResponse) GetExitCode() ExitCode
- func (*DeleteFileResponse) ProtoMessage()
- func (x *DeleteFileResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteFileResponse) Reset()
- func (x *DeleteFileResponse) String() string
- type ExitCode
- type GetFileRequest
- type GetFileResponse
- func (*GetFileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetFileResponse) GetExitCode() ExitCode
- func (x *GetFileResponse) GetFile() *HermesFile
- func (*GetFileResponse) ProtoMessage()
- func (x *GetFileResponse) ProtoReflect() protoreflect.Message
- func (x *GetFileResponse) Reset()
- func (x *GetFileResponse) String() string
- type HermesFile
- func (*HermesFile) Descriptor() ([]byte, []int)deprecated
- func (x *HermesFile) GetContents() string
- func (x *HermesFile) GetName() string
- func (x *HermesFile) GetTarget() *Target
- func (*HermesFile) ProtoMessage()
- func (x *HermesFile) ProtoReflect() protoreflect.Message
- func (x *HermesFile) Reset()
- func (x *HermesFile) String() string
- type HermesProbeDef
- func (*HermesProbeDef) Descriptor() ([]byte, []int)deprecated
- func (x *HermesProbeDef) GetApiCallLatencyAdditionalLabel() []*proto2.AdditionalLabel
- func (x *HermesProbeDef) GetApiCallLatencyDistribution() *proto1.Dist
- func (x *HermesProbeDef) GetIntervalSec() int32
- func (x *HermesProbeDef) GetProbeLatencyAdditionalLabel() []*proto2.AdditionalLabel
- func (x *HermesProbeDef) GetProbeLatencyDistribution() *proto1.Dist
- func (x *HermesProbeDef) GetProbeName() string
- func (x *HermesProbeDef) GetTargetSystem() HermesProbeDef_TargetSystem
- func (x *HermesProbeDef) GetTargets() []*Target
- func (x *HermesProbeDef) GetTimeoutSec() int32
- func (*HermesProbeDef) ProtoMessage()
- func (x *HermesProbeDef) ProtoReflect() protoreflect.Message
- func (x *HermesProbeDef) Reset()
- func (x *HermesProbeDef) String() string
- type HermesProbeDef_TargetSystem
- func (HermesProbeDef_TargetSystem) Descriptor() protoreflect.EnumDescriptor
- func (x HermesProbeDef_TargetSystem) Enum() *HermesProbeDef_TargetSystem
- func (HermesProbeDef_TargetSystem) EnumDescriptor() ([]byte, []int)deprecated
- func (x HermesProbeDef_TargetSystem) Number() protoreflect.EnumNumber
- func (x HermesProbeDef_TargetSystem) String() string
- func (HermesProbeDef_TargetSystem) Type() protoreflect.EnumType
- func (x *HermesProbeDef_TargetSystem) UnmarshalJSON(b []byte) errordeprecated
- type HermesProbeRequest
- func (*HermesProbeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HermesProbeRequest) GetProbeConfig() *HermesProbeDef
- func (*HermesProbeRequest) ProtoMessage()
- func (x *HermesProbeRequest) ProtoReflect() protoreflect.Message
- func (x *HermesProbeRequest) Reset()
- func (x *HermesProbeRequest) String() string
- type HermesProbeResponse
- type ListMonitoredSystemsRequest
- type ListMonitoredSystemsResponse
- func (*ListMonitoredSystemsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMonitoredSystemsResponse) GetTargets() []*Target
- func (*ListMonitoredSystemsResponse) ProtoMessage()
- func (x *ListMonitoredSystemsResponse) ProtoReflect() protoreflect.Message
- func (x *ListMonitoredSystemsResponse) Reset()
- func (x *ListMonitoredSystemsResponse) String() string
- type PutFileRequest
- type PutFileResponse
- type StopMonitoringSystemRequest
- func (*StopMonitoringSystemRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StopMonitoringSystemRequest) GetTargets() []*Target
- func (*StopMonitoringSystemRequest) ProtoMessage()
- func (x *StopMonitoringSystemRequest) ProtoReflect() protoreflect.Message
- func (x *StopMonitoringSystemRequest) Reset()
- func (x *StopMonitoringSystemRequest) String() string
- type StopMonitoringSystemResponse
- func (*StopMonitoringSystemResponse) Descriptor() ([]byte, []int)deprecated
- func (*StopMonitoringSystemResponse) ProtoMessage()
- func (x *StopMonitoringSystemResponse) ProtoReflect() protoreflect.Message
- func (x *StopMonitoringSystemResponse) Reset()
- func (x *StopMonitoringSystemResponse) String() string
- type Target
- func (*Target) Descriptor() ([]byte, []int)deprecated
- func (x *Target) GetApiKey() string
- func (x *Target) GetBucketName() string
- func (x *Target) GetConnectionType() Target_ConnectionType
- func (x *Target) GetName() string
- func (x *Target) GetPort() int32
- func (x *Target) GetTargetSystem() Target_TargetSystem
- func (x *Target) GetTargetUrl() string
- func (x *Target) GetTotalSpaceAllocatedMib() int64
- func (*Target) ProtoMessage()
- func (x *Target) ProtoReflect() protoreflect.Message
- func (x *Target) Reset()
- func (x *Target) String() string
- type Target_ConnectionType
- func (Target_ConnectionType) Descriptor() protoreflect.EnumDescriptor
- func (x Target_ConnectionType) Enum() *Target_ConnectionType
- func (Target_ConnectionType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Target_ConnectionType) Number() protoreflect.EnumNumber
- func (x Target_ConnectionType) String() string
- func (Target_ConnectionType) Type() protoreflect.EnumType
- type Target_TargetSystem
- func (Target_TargetSystem) Descriptor() protoreflect.EnumDescriptor
- func (x Target_TargetSystem) Enum() *Target_TargetSystem
- func (Target_TargetSystem) EnumDescriptor() ([]byte, []int)deprecated
- func (x Target_TargetSystem) Number() protoreflect.EnumNumber
- func (x Target_TargetSystem) String() string
- func (Target_TargetSystem) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
var ( ExitCode_name = map[int32]string{ 0: "SUCCESS", } ExitCode_value = map[string]int32{ "SUCCESS": 0, } )
Enum value maps for ExitCode.
var ( HermesProbeDef_TargetSystem_name = map[int32]string{ 0: "TARGET_SYSTEM_UNSPECIFIED", 1: "GCS", } HermesProbeDef_TargetSystem_value = map[string]int32{ "TARGET_SYSTEM_UNSPECIFIED": 0, "GCS": 1, } )
Enum value maps for HermesProbeDef_TargetSystem.
var ( Target_TargetSystem_name = map[int32]string{ 0: "TARGET_SYSTEM_UNSPECIFIED", 1: "GOOGLE_CLOUD_STORAGE", } Target_TargetSystem_value = map[string]int32{ "TARGET_SYSTEM_UNSPECIFIED": 0, "GOOGLE_CLOUD_STORAGE": 1, } )
Enum value maps for Target_TargetSystem.
var ( Target_ConnectionType_name = map[int32]string{ 0: "CONNECTION_TYPE_UNSPECIFIED", 1: "HTTP", 2: "HTTPS", } Target_ConnectionType_value = map[string]int32{ "CONNECTION_TYPE_UNSPECIFIED": 0, "HTTP": 1, "HTTPS": 2, } )
Enum value maps for Target_ConnectionType.
var (
// optional hermes.HermesProbeDef hermes_probe_def = 200;
E_HermesProbeDef_HermesProbeDef = &file_github_com_googleinterns_step224_2020_config_proto_probe_proto_extTypes[0]
)
Extension fields to proto2.ProbeDef.
var File_github_com_googleinterns_step224_2020_config_proto_interface_proto protoreflect.FileDescriptor
var File_github_com_googleinterns_step224_2020_config_proto_probe_proto protoreflect.FileDescriptor
var File_github_com_googleinterns_step224_2020_config_proto_service_proto protoreflect.FileDescriptor
var File_github_com_googleinterns_step224_2020_config_proto_targets_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type DeleteFileRequest ¶
type DeleteFileRequest struct { File *HermesFile `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"` // REQUIRED field // contains filtered or unexported fields }
HermesFile (name and target, contents optional) need to be specified so that Hermes knows what file to delete and from which storage system to delete it from
func (*DeleteFileRequest) Descriptor
deprecated
func (*DeleteFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteFileRequest.ProtoReflect.Descriptor instead.
func (*DeleteFileRequest) GetFile ¶
func (x *DeleteFileRequest) GetFile() *HermesFile
func (*DeleteFileRequest) ProtoMessage ¶
func (*DeleteFileRequest) ProtoMessage()
func (*DeleteFileRequest) ProtoReflect ¶
func (x *DeleteFileRequest) ProtoReflect() protoreflect.Message
func (*DeleteFileRequest) Reset ¶
func (x *DeleteFileRequest) Reset()
func (*DeleteFileRequest) String ¶
func (x *DeleteFileRequest) String() string
type DeleteFileResponse ¶
type DeleteFileResponse struct { ExitCode ExitCode `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3,enum=hermes.ExitCode" json:"exit_code,omitempty"` // REQUIRED field // contains filtered or unexported fields }
returns the exit code after the rpc DeleteFile
func (*DeleteFileResponse) Descriptor
deprecated
func (*DeleteFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteFileResponse.ProtoReflect.Descriptor instead.
func (*DeleteFileResponse) GetExitCode ¶
func (x *DeleteFileResponse) GetExitCode() ExitCode
func (*DeleteFileResponse) ProtoMessage ¶
func (*DeleteFileResponse) ProtoMessage()
func (*DeleteFileResponse) ProtoReflect ¶
func (x *DeleteFileResponse) ProtoReflect() protoreflect.Message
func (*DeleteFileResponse) Reset ¶
func (x *DeleteFileResponse) Reset()
func (*DeleteFileResponse) String ¶
func (x *DeleteFileResponse) String() string
type ExitCode ¶
type ExitCode int32
TODO (#31): Complete ExitCode enum in interface.proto
const (
ExitCode_SUCCESS ExitCode = 0
)
func (ExitCode) Descriptor ¶
func (ExitCode) Descriptor() protoreflect.EnumDescriptor
func (ExitCode) EnumDescriptor
deprecated
func (ExitCode) Number ¶
func (x ExitCode) Number() protoreflect.EnumNumber
func (ExitCode) Type ¶
func (ExitCode) Type() protoreflect.EnumType
type GetFileRequest ¶
type GetFileRequest struct { File *HermesFile `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"` // contains filtered or unexported fields }
HermesFile (name and target, contents optional) need to be specified so that Hermes knows what file to retrieve and from which storage system to retrieve it from
func (*GetFileRequest) Descriptor
deprecated
func (*GetFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.
func (*GetFileRequest) GetFile ¶
func (x *GetFileRequest) GetFile() *HermesFile
func (*GetFileRequest) ProtoMessage ¶
func (*GetFileRequest) ProtoMessage()
func (*GetFileRequest) ProtoReflect ¶
func (x *GetFileRequest) ProtoReflect() protoreflect.Message
func (*GetFileRequest) Reset ¶
func (x *GetFileRequest) Reset()
func (*GetFileRequest) String ¶
func (x *GetFileRequest) String() string
type GetFileResponse ¶
type GetFileResponse struct { ExitCode ExitCode `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3,enum=hermes.ExitCode" json:"exit_code,omitempty"` // REQUIRED field File *HermesFile `protobuf:"bytes,2,opt,name=file,proto3" json:"file,omitempty"` // OPTIONAL field // contains filtered or unexported fields }
returns the exit code after the rpc GetFile if GetFile suceeded we return the file (name and contents required) and if GetFile fails we do not
func (*GetFileResponse) Descriptor
deprecated
func (*GetFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetFileResponse.ProtoReflect.Descriptor instead.
func (*GetFileResponse) GetExitCode ¶
func (x *GetFileResponse) GetExitCode() ExitCode
func (*GetFileResponse) GetFile ¶
func (x *GetFileResponse) GetFile() *HermesFile
func (*GetFileResponse) ProtoMessage ¶
func (*GetFileResponse) ProtoMessage()
func (*GetFileResponse) ProtoReflect ¶
func (x *GetFileResponse) ProtoReflect() protoreflect.Message
func (*GetFileResponse) Reset ¶
func (x *GetFileResponse) Reset()
func (*GetFileResponse) String ¶
func (x *GetFileResponse) String() string
type HermesFile ¶
type HermesFile struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // REQUIRED field Target *Target `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` // REQUIRED field for PutFileRequest, GetFileRequest and DeleteFileRequest OPTIONAL field for GetFileResponse Contents string `protobuf:"bytes,3,opt,name=contents,proto3" json:"contents,omitempty"` // REQUIRED field for PutFileRequest OPTIONAL field for GetFileResponse // contains filtered or unexported fields }
func (*HermesFile) Descriptor
deprecated
func (*HermesFile) Descriptor() ([]byte, []int)
Deprecated: Use HermesFile.ProtoReflect.Descriptor instead.
func (*HermesFile) GetContents ¶
func (x *HermesFile) GetContents() string
func (*HermesFile) GetName ¶
func (x *HermesFile) GetName() string
func (*HermesFile) GetTarget ¶
func (x *HermesFile) GetTarget() *Target
func (*HermesFile) ProtoMessage ¶
func (*HermesFile) ProtoMessage()
func (*HermesFile) ProtoReflect ¶
func (x *HermesFile) ProtoReflect() protoreflect.Message
func (*HermesFile) Reset ¶
func (x *HermesFile) Reset()
func (*HermesFile) String ¶
func (x *HermesFile) String() string
type HermesProbeDef ¶
type HermesProbeDef struct { ProbeName *string `protobuf:"bytes,1,opt,name=probe_name,json=probeName" json:"probe_name,omitempty"` Targets []*Target `protobuf:"bytes,2,rep,name=targets" json:"targets,omitempty"` TargetSystem *HermesProbeDef_TargetSystem `` /* 131-byte string literal not displayed */ // Probing interval in seconds, default = 3600 IntervalSec *int32 `protobuf:"varint,4,opt,name=interval_sec,json=intervalSec" json:"interval_sec,omitempty"` // Probes will not retry, they will fail if they timeout. TimeoutSec *int32 `protobuf:"varint,5,opt,name=timeout_sec,json=timeoutSec" json:"timeout_sec,omitempty"` // Timeout in seconds, default = 60 // If specified, latency is stored as a distribution metric. // Measures the latency of Hermes' probes, allowing you to diagnose a network issue or issue with Hermes. // The measurement unit of latency will be seconds. ProbeLatencyDistribution *proto1.Dist `` /* 128-byte string literal not displayed */ // Measures the latency of the API calls for the relevant storage system targeted. // The measurement unit of latency will be seconds. ApiCallLatencyDistribution *proto1.Dist `` /* 136-byte string literal not displayed */ // Additional labels for the probe latency and API call latency distribution metrics. // Add as key-value pairs ProbeLatencyAdditionalLabel []*proto2.AdditionalLabel `` /* 139-byte string literal not displayed */ ApiCallLatencyAdditionalLabel []*proto2.AdditionalLabel `` /* 148-byte string literal not displayed */ // contains filtered or unexported fields }
HermesProbeDef defines the proto config for the Hermes monitor probe.
func (*HermesProbeDef) Descriptor
deprecated
func (*HermesProbeDef) Descriptor() ([]byte, []int)
Deprecated: Use HermesProbeDef.ProtoReflect.Descriptor instead.
func (*HermesProbeDef) GetApiCallLatencyAdditionalLabel ¶
func (x *HermesProbeDef) GetApiCallLatencyAdditionalLabel() []*proto2.AdditionalLabel
func (*HermesProbeDef) GetApiCallLatencyDistribution ¶
func (x *HermesProbeDef) GetApiCallLatencyDistribution() *proto1.Dist
func (*HermesProbeDef) GetIntervalSec ¶
func (x *HermesProbeDef) GetIntervalSec() int32
func (*HermesProbeDef) GetProbeLatencyAdditionalLabel ¶
func (x *HermesProbeDef) GetProbeLatencyAdditionalLabel() []*proto2.AdditionalLabel
func (*HermesProbeDef) GetProbeLatencyDistribution ¶
func (x *HermesProbeDef) GetProbeLatencyDistribution() *proto1.Dist
func (*HermesProbeDef) GetProbeName ¶
func (x *HermesProbeDef) GetProbeName() string
func (*HermesProbeDef) GetTargetSystem ¶
func (x *HermesProbeDef) GetTargetSystem() HermesProbeDef_TargetSystem
func (*HermesProbeDef) GetTargets ¶
func (x *HermesProbeDef) GetTargets() []*Target
func (*HermesProbeDef) GetTimeoutSec ¶
func (x *HermesProbeDef) GetTimeoutSec() int32
func (*HermesProbeDef) ProtoMessage ¶
func (*HermesProbeDef) ProtoMessage()
func (*HermesProbeDef) ProtoReflect ¶
func (x *HermesProbeDef) ProtoReflect() protoreflect.Message
func (*HermesProbeDef) Reset ¶
func (x *HermesProbeDef) Reset()
func (*HermesProbeDef) String ¶
func (x *HermesProbeDef) String() string
type HermesProbeDef_TargetSystem ¶
type HermesProbeDef_TargetSystem int32
TargetSystem is expected to be a storage system. It will stay constant until support for new storage systems is added.
const ( HermesProbeDef_TARGET_SYSTEM_UNSPECIFIED HermesProbeDef_TargetSystem = 0 HermesProbeDef_GCS HermesProbeDef_TargetSystem = 1 )
func (HermesProbeDef_TargetSystem) Descriptor ¶
func (HermesProbeDef_TargetSystem) Descriptor() protoreflect.EnumDescriptor
func (HermesProbeDef_TargetSystem) Enum ¶
func (x HermesProbeDef_TargetSystem) Enum() *HermesProbeDef_TargetSystem
func (HermesProbeDef_TargetSystem) EnumDescriptor
deprecated
func (HermesProbeDef_TargetSystem) EnumDescriptor() ([]byte, []int)
Deprecated: Use HermesProbeDef_TargetSystem.Descriptor instead.
func (HermesProbeDef_TargetSystem) Number ¶
func (x HermesProbeDef_TargetSystem) Number() protoreflect.EnumNumber
func (HermesProbeDef_TargetSystem) String ¶
func (x HermesProbeDef_TargetSystem) String() string
func (HermesProbeDef_TargetSystem) Type ¶
func (HermesProbeDef_TargetSystem) Type() protoreflect.EnumType
func (*HermesProbeDef_TargetSystem) UnmarshalJSON
deprecated
func (x *HermesProbeDef_TargetSystem) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type HermesProbeRequest ¶
type HermesProbeRequest struct { ProbeConfig *HermesProbeDef `protobuf:"bytes,1,opt,name=probe_config,json=probeConfig,proto3" json:"probe_config,omitempty"` // contains filtered or unexported fields }
HermesProbeRequest is used for starting monitoring a new storage system using a Hermes probe.
func (*HermesProbeRequest) Descriptor
deprecated
func (*HermesProbeRequest) Descriptor() ([]byte, []int)
Deprecated: Use HermesProbeRequest.ProtoReflect.Descriptor instead.
func (*HermesProbeRequest) GetProbeConfig ¶
func (x *HermesProbeRequest) GetProbeConfig() *HermesProbeDef
func (*HermesProbeRequest) ProtoMessage ¶
func (*HermesProbeRequest) ProtoMessage()
func (*HermesProbeRequest) ProtoReflect ¶
func (x *HermesProbeRequest) ProtoReflect() protoreflect.Message
func (*HermesProbeRequest) Reset ¶
func (x *HermesProbeRequest) Reset()
func (*HermesProbeRequest) String ¶
func (x *HermesProbeRequest) String() string
type HermesProbeResponse ¶
type HermesProbeResponse struct {
// contains filtered or unexported fields
}
TODO(#29) Add exit status to probe responses.
func (*HermesProbeResponse) Descriptor
deprecated
func (*HermesProbeResponse) Descriptor() ([]byte, []int)
Deprecated: Use HermesProbeResponse.ProtoReflect.Descriptor instead.
func (*HermesProbeResponse) ProtoMessage ¶
func (*HermesProbeResponse) ProtoMessage()
func (*HermesProbeResponse) ProtoReflect ¶
func (x *HermesProbeResponse) ProtoReflect() protoreflect.Message
func (*HermesProbeResponse) Reset ¶
func (x *HermesProbeResponse) Reset()
func (*HermesProbeResponse) String ¶
func (x *HermesProbeResponse) String() string
type ListMonitoredSystemsRequest ¶
type ListMonitoredSystemsRequest struct {
// contains filtered or unexported fields
}
func (*ListMonitoredSystemsRequest) Descriptor
deprecated
func (*ListMonitoredSystemsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListMonitoredSystemsRequest.ProtoReflect.Descriptor instead.
func (*ListMonitoredSystemsRequest) ProtoMessage ¶
func (*ListMonitoredSystemsRequest) ProtoMessage()
func (*ListMonitoredSystemsRequest) ProtoReflect ¶
func (x *ListMonitoredSystemsRequest) ProtoReflect() protoreflect.Message
func (*ListMonitoredSystemsRequest) Reset ¶
func (x *ListMonitoredSystemsRequest) Reset()
func (*ListMonitoredSystemsRequest) String ¶
func (x *ListMonitoredSystemsRequest) String() string
type ListMonitoredSystemsResponse ¶
type ListMonitoredSystemsResponse struct { // TODO(#29) Add exit status to probe response. Targets []*Target `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"` // contains filtered or unexported fields }
ListMonitoredSystemsResponse message holds the list of targets returned by ListMonitoredStorageSystems()
func (*ListMonitoredSystemsResponse) Descriptor
deprecated
func (*ListMonitoredSystemsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListMonitoredSystemsResponse.ProtoReflect.Descriptor instead.
func (*ListMonitoredSystemsResponse) GetTargets ¶
func (x *ListMonitoredSystemsResponse) GetTargets() []*Target
func (*ListMonitoredSystemsResponse) ProtoMessage ¶
func (*ListMonitoredSystemsResponse) ProtoMessage()
func (*ListMonitoredSystemsResponse) ProtoReflect ¶
func (x *ListMonitoredSystemsResponse) ProtoReflect() protoreflect.Message
func (*ListMonitoredSystemsResponse) Reset ¶
func (x *ListMonitoredSystemsResponse) Reset()
func (*ListMonitoredSystemsResponse) String ¶
func (x *ListMonitoredSystemsResponse) String() string
type PutFileRequest ¶
type PutFileRequest struct { File *HermesFile `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"` // contains filtered or unexported fields }
HermesFile (name, contents and target) need to be specified so that Hermes knows what file to create, and which storage system to create it on
func (*PutFileRequest) Descriptor
deprecated
func (*PutFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use PutFileRequest.ProtoReflect.Descriptor instead.
func (*PutFileRequest) GetFile ¶
func (x *PutFileRequest) GetFile() *HermesFile
func (*PutFileRequest) ProtoMessage ¶
func (*PutFileRequest) ProtoMessage()
func (*PutFileRequest) ProtoReflect ¶
func (x *PutFileRequest) ProtoReflect() protoreflect.Message
func (*PutFileRequest) Reset ¶
func (x *PutFileRequest) Reset()
func (*PutFileRequest) String ¶
func (x *PutFileRequest) String() string
type PutFileResponse ¶
type PutFileResponse struct { ExitCode ExitCode `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3,enum=hermes.ExitCode" json:"exit_code,omitempty"` // REQUIRED field // contains filtered or unexported fields }
returns the exit code after the rpc GetFile
func (*PutFileResponse) Descriptor
deprecated
func (*PutFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use PutFileResponse.ProtoReflect.Descriptor instead.
func (*PutFileResponse) GetExitCode ¶
func (x *PutFileResponse) GetExitCode() ExitCode
func (*PutFileResponse) ProtoMessage ¶
func (*PutFileResponse) ProtoMessage()
func (*PutFileResponse) ProtoReflect ¶
func (x *PutFileResponse) ProtoReflect() protoreflect.Message
func (*PutFileResponse) Reset ¶
func (x *PutFileResponse) Reset()
func (*PutFileResponse) String ¶
func (x *PutFileResponse) String() string
type StopMonitoringSystemRequest ¶
type StopMonitoringSystemRequest struct { Targets []*Target `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"` // contains filtered or unexported fields }
StopMonitoringSystemRequest specifies a target so that Hermes knows which target to stop monitoring.
func (*StopMonitoringSystemRequest) Descriptor
deprecated
func (*StopMonitoringSystemRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopMonitoringSystemRequest.ProtoReflect.Descriptor instead.
func (*StopMonitoringSystemRequest) GetTargets ¶
func (x *StopMonitoringSystemRequest) GetTargets() []*Target
func (*StopMonitoringSystemRequest) ProtoMessage ¶
func (*StopMonitoringSystemRequest) ProtoMessage()
func (*StopMonitoringSystemRequest) ProtoReflect ¶
func (x *StopMonitoringSystemRequest) ProtoReflect() protoreflect.Message
func (*StopMonitoringSystemRequest) Reset ¶
func (x *StopMonitoringSystemRequest) Reset()
func (*StopMonitoringSystemRequest) String ¶
func (x *StopMonitoringSystemRequest) String() string
type StopMonitoringSystemResponse ¶
type StopMonitoringSystemResponse struct {
// contains filtered or unexported fields
}
TODO(#29) Add exit status for probe responses.
func (*StopMonitoringSystemResponse) Descriptor
deprecated
func (*StopMonitoringSystemResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopMonitoringSystemResponse.ProtoReflect.Descriptor instead.
func (*StopMonitoringSystemResponse) ProtoMessage ¶
func (*StopMonitoringSystemResponse) ProtoMessage()
func (*StopMonitoringSystemResponse) ProtoReflect ¶
func (x *StopMonitoringSystemResponse) ProtoReflect() protoreflect.Message
func (*StopMonitoringSystemResponse) Reset ¶
func (x *StopMonitoringSystemResponse) Reset()
func (*StopMonitoringSystemResponse) String ¶
func (x *StopMonitoringSystemResponse) String() string
type Target ¶
type Target struct { // Name associated with this target instance. // For GCS, this is the project name. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` TargetSystem Target_TargetSystem `` /* 130-byte string literal not displayed */ ConnectionType Target_ConnectionType `` /* 138-byte string literal not displayed */ // REQUIRED for Ceph S3 API // Port for connecting to Ceph S3 API Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"` // REQUIRED for Ceph S3 API // GCS uses service account credentials instead. ApiKey string `protobuf:"bytes,5,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"` TotalSpaceAllocatedMib int64 `` /* 132-byte string literal not displayed */ // URL for connecting to the the API of the target storage system. TargetUrl string `protobuf:"bytes,7,opt,name=target_url,json=targetUrl,proto3" json:"target_url,omitempty"` // Name for bucket used by Hermes on this target storage system. BucketName string `protobuf:"bytes,8,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"` // contains filtered or unexported fields }
TargetDefinition contains all of the metadata necessary for Hermes to establish a connection to a storage system. Every probe request will require one or more targets.
func (*Target) Descriptor
deprecated
func (*Target) GetBucketName ¶
func (*Target) GetConnectionType ¶
func (x *Target) GetConnectionType() Target_ConnectionType
func (*Target) GetTargetSystem ¶
func (x *Target) GetTargetSystem() Target_TargetSystem
func (*Target) GetTargetUrl ¶
func (*Target) GetTotalSpaceAllocatedMib ¶
func (*Target) ProtoMessage ¶
func (*Target) ProtoMessage()
func (*Target) ProtoReflect ¶
func (x *Target) ProtoReflect() protoreflect.Message
type Target_ConnectionType ¶
type Target_ConnectionType int32
TODO(#30) Establish connection method for GCS and Ceph using Go libraries.
const ( Target_CONNECTION_TYPE_UNSPECIFIED Target_ConnectionType = 0 Target_HTTP Target_ConnectionType = 1 Target_HTTPS Target_ConnectionType = 2 )
func (Target_ConnectionType) Descriptor ¶
func (Target_ConnectionType) Descriptor() protoreflect.EnumDescriptor
func (Target_ConnectionType) Enum ¶
func (x Target_ConnectionType) Enum() *Target_ConnectionType
func (Target_ConnectionType) EnumDescriptor
deprecated
func (Target_ConnectionType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Target_ConnectionType.Descriptor instead.
func (Target_ConnectionType) Number ¶
func (x Target_ConnectionType) Number() protoreflect.EnumNumber
func (Target_ConnectionType) String ¶
func (x Target_ConnectionType) String() string
func (Target_ConnectionType) Type ¶
func (Target_ConnectionType) Type() protoreflect.EnumType
type Target_TargetSystem ¶
type Target_TargetSystem int32
TargetSystem is expected to be a storage system. It will stay constant until support for new storage systems is added.
const ( Target_TARGET_SYSTEM_UNSPECIFIED Target_TargetSystem = 0 Target_GOOGLE_CLOUD_STORAGE Target_TargetSystem = 1 )
func (Target_TargetSystem) Descriptor ¶
func (Target_TargetSystem) Descriptor() protoreflect.EnumDescriptor
func (Target_TargetSystem) Enum ¶
func (x Target_TargetSystem) Enum() *Target_TargetSystem
func (Target_TargetSystem) EnumDescriptor
deprecated
func (Target_TargetSystem) EnumDescriptor() ([]byte, []int)
Deprecated: Use Target_TargetSystem.Descriptor instead.
func (Target_TargetSystem) Number ¶
func (x Target_TargetSystem) Number() protoreflect.EnumNumber
func (Target_TargetSystem) String ¶
func (x Target_TargetSystem) String() string
func (Target_TargetSystem) Type ¶
func (Target_TargetSystem) Type() protoreflect.EnumType