svc

package
v0.0.0-...-501dce0 Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	NotificationType_name = map[int32]string{
		0: "NOTIFICATIONUNKNOWN",
		1: "NOTIFICATIONLEASEREQUESTACK",
		2: "NOTIFICATIONLEASEREQUESTEXPIRED",
		3: "NOTIFICATIONLEASEAVAILABLE",
		4: "NOTIFICATIONLEASE",
	}
	NotificationType_value = map[string]int32{
		"NOTIFICATIONUNKNOWN":             0,
		"NOTIFICATIONLEASEREQUESTACK":     1,
		"NOTIFICATIONLEASEREQUESTEXPIRED": 2,
		"NOTIFICATIONLEASEAVAILABLE":      3,
		"NOTIFICATIONLEASE":               4,
	}
)

Enum value maps for NotificationType.

View Source 
var (
	ClientStatus_name = map[int32]string{
		0: "CLIENTUNKNOWN",
		1: "CLIENTALIVE",
		2: "CLIENTDEAD",
		3: "CLIENTLEFT",
	}
	ClientStatus_value = map[string]int32{
		"CLIENTUNKNOWN": 0,
		"CLIENTALIVE":   1,
		"CLIENTDEAD":    2,
		"CLIENTLEFT":    3,
	}
)

Enum value maps for ClientStatus.

View Source 
var (
	VolumeStatus_name = map[int32]string{
		0: "VOLUMEUNKNOWN",
		1: "VOLUMEAVAILABLE",
		2: "VOLUMELEASEPENDING",
		3: "VOLUMELEASED",
	}
	VolumeStatus_value = map[string]int32{
		"VOLUMEUNKNOWN":      0,
		"VOLUMEAVAILABLE":    1,
		"VOLUMELEASEPENDING": 2,
		"VOLUMELEASED":       3,
	}
)

Enum value maps for VolumeStatus.

View Source 
var (
	LeaseStatus_name = map[int32]string{
		0: "LEASEUNKNOWN",
		1: "LEASEASSIGNING",
		2: "LEASEASSIGNED",
		3: "LEASERELEASING",
	}
	LeaseStatus_value = map[string]int32{
		"LEASEUNKNOWN":   0,
		"LEASEASSIGNING": 1,
		"LEASEASSIGNED":  2,
		"LEASERELEASING": 3,
	}
)

Enum value maps for LeaseStatus.

View Source 
var File_svc_volchestrator_proto protoreflect.FileDescriptor
View Source 
var VolchestratorAdmin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "volchestrator.VolchestratorAdmin",
	HandlerType: (*VolchestratorAdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListClients",
			Handler:    _VolchestratorAdmin_ListClients_Handler,
		},
		{
			MethodName: "GetVolume",
			Handler:    _VolchestratorAdmin_GetVolume_Handler,
		},
		{
			MethodName: "ListVolumes",
			Handler:    _VolchestratorAdmin_ListVolumes_Handler,
		},
		{
			MethodName: "AddVolume",
			Handler:    _VolchestratorAdmin_AddVolume_Handler,
		},
		{
			MethodName: "UpdateVolume",
			Handler:    _VolchestratorAdmin_UpdateVolume_Handler,
		},
		{
			MethodName: "DeleteVolume",
			Handler:    _VolchestratorAdmin_DeleteVolume_Handler,
		},
		{
			MethodName: "ListLeases",
			Handler:    _VolchestratorAdmin_ListLeases_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "svc/volchestrator.proto",
}

VolchestratorAdmin_ServiceDesc is the grpc.ServiceDesc for VolchestratorAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Volchestrator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "volchestrator.Volchestrator",
	HandlerType: (*VolchestratorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Volchestrator_Register_Handler,
		},
		{
			MethodName: "Deregister",
			Handler:    _Volchestrator_Deregister_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _Volchestrator_Heartbeat_Handler,
		},
		{
			MethodName: "Acknowledge",
			Handler:    _Volchestrator_Acknowledge_Handler,
		},
		{
			MethodName: "SubmitLeaseRequest",
			Handler:    _Volchestrator_SubmitLeaseRequest_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchNotifications",
			Handler:       _Volchestrator_WatchNotifications_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "svc/volchestrator.proto",
}

Volchestrator_ServiceDesc is the grpc.ServiceDesc for Volchestrator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterVolchestratorAdminServer 

func RegisterVolchestratorAdminServer(s grpc.ServiceRegistrar, srv VolchestratorAdminServer)

func RegisterVolchestratorServer 

func RegisterVolchestratorServer(s grpc.ServiceRegistrar, srv VolchestratorServer)

Types

type Acknowledgement 

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

func (*Acknowledgement) Descriptor deprecated 

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

Deprecated: Use Acknowledgement.ProtoReflect.Descriptor instead.

func (*Acknowledgement) GetId 

func (x *Acknowledgement) GetId() string

func (*Acknowledgement) ProtoMessage 

func (*Acknowledgement) ProtoMessage()

func (*Acknowledgement) ProtoReflect 

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

func (*Acknowledgement) Reset 

func (x *Acknowledgement) Reset()

func (*Acknowledgement) String 

func (x *Acknowledgement) String() string

type ClientInfo 

type ClientInfo struct {
	Id           string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ClientStatus ClientStatus           `protobuf:"varint,2,opt,name=clientStatus,proto3,enum=volchestrator.ClientStatus" json:"clientStatus,omitempty"`
	FirstSeen    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=firstSeen,proto3" json:"firstSeen,omitempty"`
	LastSeen     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=lastSeen,proto3" json:"lastSeen,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientInfo) Descriptor deprecated 

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

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetClientStatus 

func (x *ClientInfo) GetClientStatus() ClientStatus

func (*ClientInfo) GetFirstSeen 

func (x *ClientInfo) GetFirstSeen() *timestamppb.Timestamp

func (*ClientInfo) GetId 

func (x *ClientInfo) GetId() string

func (*ClientInfo) GetLastSeen 

func (x *ClientInfo) GetLastSeen() *timestamppb.Timestamp

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect 

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

func (*ClientInfo) Reset 

func (x *ClientInfo) Reset()

func (*ClientInfo) String 

func (x *ClientInfo) String() string

type ClientList 

type ClientList struct {
	Info []*ClientInfo `protobuf:"bytes,1,rep,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientList) Descriptor deprecated 

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

Deprecated: Use ClientList.ProtoReflect.Descriptor instead.

func (*ClientList) GetInfo 

func (x *ClientList) GetInfo() []*ClientInfo

func (*ClientList) ProtoMessage 

func (*ClientList) ProtoMessage()

func (*ClientList) ProtoReflect 

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

func (*ClientList) Reset 

func (x *ClientList) Reset()

func (*ClientList) String 

func (x *ClientList) String() string

type ClientStatus 

type ClientStatus int32
const (
	ClientStatus_CLIENTUNKNOWN ClientStatus = 0
	ClientStatus_CLIENTALIVE   ClientStatus = 1
	ClientStatus_CLIENTDEAD    ClientStatus = 2
	ClientStatus_CLIENTLEFT    ClientStatus = 3
)

func (ClientStatus) Descriptor 

func (ClientStatus) Descriptor() protoreflect.EnumDescriptor

func (ClientStatus) Enum 

func (x ClientStatus) Enum() *ClientStatus

func (ClientStatus) EnumDescriptor deprecated 

func (ClientStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use ClientStatus.Descriptor instead.

func (ClientStatus) Number 

func (x ClientStatus) Number() protoreflect.EnumNumber

func (ClientStatus) String 

func (x ClientStatus) String() string

func (ClientStatus) Type 

func (ClientStatus) Type() protoreflect.EnumType

type DeregisterMessage 

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

func (*DeregisterMessage) Descriptor deprecated 

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

Deprecated: Use DeregisterMessage.ProtoReflect.Descriptor instead.

func (*DeregisterMessage) GetId 

func (x *DeregisterMessage) GetId() string

func (*DeregisterMessage) ProtoMessage 

func (*DeregisterMessage) ProtoMessage()

func (*DeregisterMessage) ProtoReflect 

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

func (*DeregisterMessage) Reset 

func (x *DeregisterMessage) Reset()

func (*DeregisterMessage) String 

func (x *DeregisterMessage) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type HeartbeatMessage 

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

func (*HeartbeatMessage) Descriptor deprecated 

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

Deprecated: Use HeartbeatMessage.ProtoReflect.Descriptor instead.

func (*HeartbeatMessage) GetId 

func (x *HeartbeatMessage) GetId() string

func (*HeartbeatMessage) ProtoMessage 

func (*HeartbeatMessage) ProtoMessage()

func (*HeartbeatMessage) ProtoReflect 

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

func (*HeartbeatMessage) Reset 

func (x *HeartbeatMessage) Reset()

func (*HeartbeatMessage) String 

func (x *HeartbeatMessage) String() string

type HeartbeatResponse 

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

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetId 

func (x *HeartbeatResponse) GetId() string

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type Lease 

type Lease struct {
	LeaseId  string                 `protobuf:"bytes,1,opt,name=leaseId,proto3" json:"leaseId,omitempty"`
	ClientId string                 `protobuf:"bytes,2,opt,name=clientId,proto3" json:"clientId,omitempty"`
	VolumeId string                 `protobuf:"bytes,3,opt,name=volumeId,proto3" json:"volumeId,omitempty"`
	Expires  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`
	Status   LeaseStatus            `protobuf:"varint,5,opt,name=status,proto3,enum=volchestrator.LeaseStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Lease) Descriptor deprecated 

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

Deprecated: Use Lease.ProtoReflect.Descriptor instead.

func (*Lease) GetClientId 

func (x *Lease) GetClientId() string

func (*Lease) GetExpires 

func (x *Lease) GetExpires() *timestamppb.Timestamp

func (*Lease) GetLeaseId 

func (x *Lease) GetLeaseId() string

func (*Lease) GetStatus 

func (x *Lease) GetStatus() LeaseStatus

func (*Lease) GetVolumeId 

func (x *Lease) GetVolumeId() string

func (*Lease) ProtoMessage 

func (*Lease) ProtoMessage()

func (*Lease) ProtoReflect 

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

func (*Lease) Reset 

func (x *Lease) Reset()

func (*Lease) String 

func (x *Lease) String() string

type LeaseList 

type LeaseList struct {
	Leases []*Lease `protobuf:"bytes,1,rep,name=leases,proto3" json:"leases,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaseList) Descriptor deprecated 

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

Deprecated: Use LeaseList.ProtoReflect.Descriptor instead.

func (*LeaseList) GetLeases 

func (x *LeaseList) GetLeases() []*Lease

func (*LeaseList) ProtoMessage 

func (*LeaseList) ProtoMessage()

func (*LeaseList) ProtoReflect 

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

func (*LeaseList) Reset 

func (x *LeaseList) Reset()

func (*LeaseList) String 

func (x *LeaseList) String() string

type LeaseRequest 

type LeaseRequest struct {
	ClientId         string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Tag              string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	AvailabilityZone string `protobuf:"bytes,3,opt,name=availabilityZone,proto3" json:"availabilityZone,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaseRequest) Descriptor deprecated 

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

Deprecated: Use LeaseRequest.ProtoReflect.Descriptor instead.

func (*LeaseRequest) GetAvailabilityZone 

func (x *LeaseRequest) GetAvailabilityZone() string

func (*LeaseRequest) GetClientId 

func (x *LeaseRequest) GetClientId() string

func (*LeaseRequest) GetTag 

func (x *LeaseRequest) GetTag() string

func (*LeaseRequest) ProtoMessage 

func (*LeaseRequest) ProtoMessage()

func (*LeaseRequest) ProtoReflect 

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

func (*LeaseRequest) Reset 

func (x *LeaseRequest) Reset()

func (*LeaseRequest) String 

func (x *LeaseRequest) String() string

type LeaseStatus 

type LeaseStatus int32
const (
	LeaseStatus_LEASEUNKNOWN   LeaseStatus = 0
	LeaseStatus_LEASEASSIGNING LeaseStatus = 1
	LeaseStatus_LEASEASSIGNED  LeaseStatus = 2
	LeaseStatus_LEASERELEASING LeaseStatus = 3
)

func (LeaseStatus) Descriptor 

func (LeaseStatus) Descriptor() protoreflect.EnumDescriptor

func (LeaseStatus) Enum 

func (x LeaseStatus) Enum() *LeaseStatus

func (LeaseStatus) EnumDescriptor deprecated 

func (LeaseStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use LeaseStatus.Descriptor instead.

func (LeaseStatus) Number 

func (x LeaseStatus) Number() protoreflect.EnumNumber

func (LeaseStatus) String 

func (x LeaseStatus) String() string

func (LeaseStatus) Type 

func (LeaseStatus) Type() protoreflect.EnumType

type Notification 

type Notification struct {
	Id      string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type    NotificationType `protobuf:"varint,2,opt,name=type,proto3,enum=volchestrator.NotificationType" json:"type,omitempty"`
	Message string           `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Notification) Descriptor deprecated 

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetId 

func (x *Notification) GetId() string

func (*Notification) GetMessage 

func (x *Notification) GetMessage() string

func (*Notification) GetType 

func (x *Notification) GetType() NotificationType

func (*Notification) ProtoMessage 

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect 

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

func (*Notification) Reset 

func (x *Notification) Reset()

func (*Notification) String 

func (x *Notification) String() string

type NotificationType 

type NotificationType int32
const (
	NotificationType_NOTIFICATIONUNKNOWN             NotificationType = 0
	NotificationType_NOTIFICATIONLEASEREQUESTACK     NotificationType = 1
	NotificationType_NOTIFICATIONLEASEREQUESTEXPIRED NotificationType = 2
	NotificationType_NOTIFICATIONLEASEAVAILABLE      NotificationType = 3
	NotificationType_NOTIFICATIONLEASE               NotificationType = 4
)

func (NotificationType) Descriptor 

func (NotificationType) Descriptor() protoreflect.EnumDescriptor

func (NotificationType) Enum 

func (x NotificationType) Enum() *NotificationType

func (NotificationType) EnumDescriptor deprecated 

func (NotificationType) EnumDescriptor() ([]byte, []int)

Deprecated: Use NotificationType.Descriptor instead.

func (NotificationType) Number 

func (x NotificationType) Number() protoreflect.EnumNumber

func (NotificationType) String 

func (x NotificationType) String() string

func (NotificationType) Type 

func (NotificationType) Type() protoreflect.EnumType

type NotificationWatchMessage 

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

func (*NotificationWatchMessage) Descriptor deprecated 

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

Deprecated: Use NotificationWatchMessage.ProtoReflect.Descriptor instead.

func (*NotificationWatchMessage) GetId 

func (x *NotificationWatchMessage) GetId() string

func (*NotificationWatchMessage) ProtoMessage 

func (*NotificationWatchMessage) ProtoMessage()

func (*NotificationWatchMessage) ProtoReflect 

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

func (*NotificationWatchMessage) Reset 

func (x *NotificationWatchMessage) Reset()

func (*NotificationWatchMessage) String 

func (x *NotificationWatchMessage) String() string

type RegisterMessage 

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

func (*RegisterMessage) Descriptor deprecated 

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

Deprecated: Use RegisterMessage.ProtoReflect.Descriptor instead.

func (*RegisterMessage) GetId 

func (x *RegisterMessage) GetId() string

func (*RegisterMessage) ProtoMessage 

func (*RegisterMessage) ProtoMessage()

func (*RegisterMessage) ProtoReflect 

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

func (*RegisterMessage) Reset 

func (x *RegisterMessage) Reset()

func (*RegisterMessage) String 

func (x *RegisterMessage) String() string

type UnimplementedVolchestratorAdminServer 

type UnimplementedVolchestratorAdminServer struct {
}

UnimplementedVolchestratorAdminServer must be embedded to have forward compatible implementations.

func (UnimplementedVolchestratorAdminServer) AddVolume 

func (UnimplementedVolchestratorAdminServer) AddVolume(context.Context, *Volume) (*Volume, error)

func (UnimplementedVolchestratorAdminServer) DeleteVolume 

func (UnimplementedVolchestratorAdminServer) DeleteVolume(context.Context, *VolumeID) (*Empty, error)

func (UnimplementedVolchestratorAdminServer) GetVolume 

func (UnimplementedVolchestratorAdminServer) GetVolume(context.Context, *VolumeID) (*Volume, error)

func (UnimplementedVolchestratorAdminServer) ListClients 

func (UnimplementedVolchestratorAdminServer) ListClients(context.Context, *Empty) (*ClientList, error)

func (UnimplementedVolchestratorAdminServer) ListLeases 

func (UnimplementedVolchestratorAdminServer) ListLeases(context.Context, *Empty) (*LeaseList, error)

func (UnimplementedVolchestratorAdminServer) ListVolumes 

func (UnimplementedVolchestratorAdminServer) ListVolumes(context.Context, *Empty) (*VolumeList, error)

func (UnimplementedVolchestratorAdminServer) UpdateVolume 

func (UnimplementedVolchestratorAdminServer) UpdateVolume(context.Context, *Volume) (*Volume, error)

type UnimplementedVolchestratorServer 

type UnimplementedVolchestratorServer struct {
}

UnimplementedVolchestratorServer must be embedded to have forward compatible implementations.

func (UnimplementedVolchestratorServer) Acknowledge 

func (UnimplementedVolchestratorServer) Acknowledge(context.Context, *Acknowledgement) (*Empty, error)

func (UnimplementedVolchestratorServer) Deregister 

func (UnimplementedVolchestratorServer) Deregister(context.Context, *DeregisterMessage) (*Empty, error)

func (UnimplementedVolchestratorServer) Heartbeat 

func (UnimplementedVolchestratorServer) Heartbeat(context.Context, *HeartbeatMessage) (*HeartbeatResponse, error)

func (UnimplementedVolchestratorServer) Register 

func (UnimplementedVolchestratorServer) Register(context.Context, *RegisterMessage) (*Empty, error)

func (UnimplementedVolchestratorServer) SubmitLeaseRequest 

func (UnimplementedVolchestratorServer) SubmitLeaseRequest(context.Context, *LeaseRequest) (*Empty, error)

func (UnimplementedVolchestratorServer) WatchNotifications 

func (UnimplementedVolchestratorServer) WatchNotifications(*NotificationWatchMessage, Volchestrator_WatchNotificationsServer) error

type UnsafeVolchestratorAdminServer 

type UnsafeVolchestratorAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeVolchestratorAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VolchestratorAdminServer will result in compilation errors.

type UnsafeVolchestratorServer 

type UnsafeVolchestratorServer interface {
	// contains filtered or unexported methods
}

UnsafeVolchestratorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VolchestratorServer will result in compilation errors.

type VolchestratorAdminClient 

type VolchestratorAdminClient interface {
	ListClients(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ClientList, error)
	GetVolume(ctx context.Context, in *VolumeID, opts ...grpc.CallOption) (*Volume, error)
	ListVolumes(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VolumeList, error)
	AddVolume(ctx context.Context, in *Volume, opts ...grpc.CallOption) (*Volume, error)
	UpdateVolume(ctx context.Context, in *Volume, opts ...grpc.CallOption) (*Volume, error)
	DeleteVolume(ctx context.Context, in *VolumeID, opts ...grpc.CallOption) (*Empty, error)
	ListLeases(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*LeaseList, error)
}

VolchestratorAdminClient is the client API for VolchestratorAdmin 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 NewVolchestratorAdminClient 

func NewVolchestratorAdminClient(cc grpc.ClientConnInterface) VolchestratorAdminClient

type VolchestratorAdminServer 

type VolchestratorAdminServer interface {
	ListClients(context.Context, *Empty) (*ClientList, error)
	GetVolume(context.Context, *VolumeID) (*Volume, error)
	ListVolumes(context.Context, *Empty) (*VolumeList, error)
	AddVolume(context.Context, *Volume) (*Volume, error)
	UpdateVolume(context.Context, *Volume) (*Volume, error)
	DeleteVolume(context.Context, *VolumeID) (*Empty, error)
	ListLeases(context.Context, *Empty) (*LeaseList, error)
	// contains filtered or unexported methods
}

VolchestratorAdminServer is the server API for VolchestratorAdmin service. All implementations must embed UnimplementedVolchestratorAdminServer for forward compatibility

type VolchestratorClient 

type VolchestratorClient interface {
	Register(ctx context.Context, in *RegisterMessage, opts ...grpc.CallOption) (*Empty, error)
	Deregister(ctx context.Context, in *DeregisterMessage, opts ...grpc.CallOption) (*Empty, error)
	Heartbeat(ctx context.Context, in *HeartbeatMessage, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	WatchNotifications(ctx context.Context, in *NotificationWatchMessage, opts ...grpc.CallOption) (Volchestrator_WatchNotificationsClient, error)
	Acknowledge(ctx context.Context, in *Acknowledgement, opts ...grpc.CallOption) (*Empty, error)
	SubmitLeaseRequest(ctx context.Context, in *LeaseRequest, opts ...grpc.CallOption) (*Empty, error)
}

VolchestratorClient is the client API for Volchestrator 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 NewVolchestratorClient 

func NewVolchestratorClient(cc grpc.ClientConnInterface) VolchestratorClient

type VolchestratorServer 

type VolchestratorServer interface {
	Register(context.Context, *RegisterMessage) (*Empty, error)
	Deregister(context.Context, *DeregisterMessage) (*Empty, error)
	Heartbeat(context.Context, *HeartbeatMessage) (*HeartbeatResponse, error)
	WatchNotifications(*NotificationWatchMessage, Volchestrator_WatchNotificationsServer) error
	Acknowledge(context.Context, *Acknowledgement) (*Empty, error)
	SubmitLeaseRequest(context.Context, *LeaseRequest) (*Empty, error)
	// contains filtered or unexported methods
}

VolchestratorServer is the server API for Volchestrator service. All implementations must embed UnimplementedVolchestratorServer for forward compatibility

type Volchestrator_WatchNotificationsClient 

type Volchestrator_WatchNotificationsClient interface {
	Recv() (*Notification, error)
	grpc.ClientStream
}

type Volchestrator_WatchNotificationsServer 

type Volchestrator_WatchNotificationsServer interface {
	Send(*Notification) error
	grpc.ServerStream
}

type Volume 

type Volume struct {
	Id               string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Tags             []string     `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	AvailabilityZone string       `protobuf:"bytes,3,opt,name=availabilityZone,proto3" json:"availabilityZone,omitempty"`
	Status           VolumeStatus `protobuf:"varint,4,opt,name=status,proto3,enum=volchestrator.VolumeStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Volume) Descriptor deprecated 

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

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetAvailabilityZone 

func (x *Volume) GetAvailabilityZone() string

func (*Volume) GetId 

func (x *Volume) GetId() string

func (*Volume) GetStatus 

func (x *Volume) GetStatus() VolumeStatus

func (*Volume) GetTags 

func (x *Volume) GetTags() []string

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect 

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

func (*Volume) Reset 

func (x *Volume) Reset()

func (*Volume) String 

func (x *Volume) String() string

type VolumeID 

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

func (*VolumeID) Descriptor deprecated 

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

Deprecated: Use VolumeID.ProtoReflect.Descriptor instead.

func (*VolumeID) GetId 

func (x *VolumeID) GetId() string

func (*VolumeID) ProtoMessage 

func (*VolumeID) ProtoMessage()

func (*VolumeID) ProtoReflect 

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

func (*VolumeID) Reset 

func (x *VolumeID) Reset()

func (*VolumeID) String 

func (x *VolumeID) String() string

type VolumeList 

type VolumeList struct {
	Volumes []*Volume `protobuf:"bytes,1,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeList) Descriptor deprecated 

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

Deprecated: Use VolumeList.ProtoReflect.Descriptor instead.

func (*VolumeList) GetVolumes 

func (x *VolumeList) GetVolumes() []*Volume

func (*VolumeList) ProtoMessage 

func (*VolumeList) ProtoMessage()

func (*VolumeList) ProtoReflect 

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

func (*VolumeList) Reset 

func (x *VolumeList) Reset()

func (*VolumeList) String 

func (x *VolumeList) String() string

type VolumeStatus 

type VolumeStatus int32
const (
	VolumeStatus_VOLUMEUNKNOWN      VolumeStatus = 0
	VolumeStatus_VOLUMEAVAILABLE    VolumeStatus = 1
	VolumeStatus_VOLUMELEASEPENDING VolumeStatus = 2
	VolumeStatus_VOLUMELEASED       VolumeStatus = 3
)

func (VolumeStatus) Descriptor 

func (VolumeStatus) Descriptor() protoreflect.EnumDescriptor

func (VolumeStatus) Enum 

func (x VolumeStatus) Enum() *VolumeStatus

func (VolumeStatus) EnumDescriptor deprecated 

func (VolumeStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use VolumeStatus.Descriptor instead.

func (VolumeStatus) Number 

func (x VolumeStatus) Number() protoreflect.EnumNumber

func (VolumeStatus) String 

func (x VolumeStatus) String() string

func (VolumeStatus) Type 

func (VolumeStatus) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.