rpc

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: May 19, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package rpc is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var OperationStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "INITIALIZED",
	2: "STARTED",
	3: "COMPLETED",
	4: "FAILED",
}
View Source 
var OperationStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"INITIALIZED": 1,
	"STARTED":     2,
	"COMPLETED":   3,
	"FAILED":      4,
}

Functions

func RegisterAdminServer 

func RegisterAdminServer(s *grpc.Server, srv AdminServer)

func RegisterCassyHandler 

func RegisterCassyHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterCassyHandler registers the http handlers for service Cassy to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterCassyHandlerClient 

func RegisterCassyHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CassyClient) error

RegisterCassyHandlerClient registers the http handlers for service Cassy to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "CassyClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "CassyClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "CassyClient" to call the correct interceptors.

func RegisterCassyHandlerFromEndpoint 

func RegisterCassyHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterCassyHandlerFromEndpoint is same as RegisterCassyHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterCassyServer 

func RegisterCassyServer(s *grpc.Server, srv CassyServer)

Types

type AdminClient 

type AdminClient interface {
	Pause(ctx context.Context, in *PauseRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Unpause(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	Stats(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*StatsResponse, error)
}

AdminClient is the client API for Admin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAdminClient 

func NewAdminClient(cc *grpc.ClientConn) AdminClient

type AdminServer 

type AdminServer interface {
	Pause(context.Context, *PauseRequest) (*empty.Empty, error)
	Unpause(context.Context, *empty.Empty) (*empty.Empty, error)
	Stats(context.Context, *empty.Empty) (*StatsResponse, error)
}

AdminServer is the server API for Admin service.

type BackupListingRequest 

type BackupListingRequest struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	TargetIp             string   `protobuf:"bytes,2,opt,name=target_ip,json=targetIp,proto3" json:"target_ip,omitempty"`
	Limit                int32    `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	SnapshotId           string   `protobuf:"bytes,4,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupListingRequest) Descriptor 

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

func (*BackupListingRequest) GetClusterId 

func (m *BackupListingRequest) GetClusterId() string

func (*BackupListingRequest) GetLimit 

func (m *BackupListingRequest) GetLimit() int32

func (*BackupListingRequest) GetSnapshotId 

func (m *BackupListingRequest) GetSnapshotId() string

func (*BackupListingRequest) GetTargetIp 

func (m *BackupListingRequest) GetTargetIp() string

func (*BackupListingRequest) ProtoMessage 

func (*BackupListingRequest) ProtoMessage()

func (*BackupListingRequest) Reset 

func (m *BackupListingRequest) Reset()

func (*BackupListingRequest) String 

func (m *BackupListingRequest) String() string

func (*BackupListingRequest) XXX_DiscardUnknown 

func (m *BackupListingRequest) XXX_DiscardUnknown()

func (*BackupListingRequest) XXX_Marshal 

func (m *BackupListingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupListingRequest) XXX_Merge 

func (m *BackupListingRequest) XXX_Merge(src proto.Message)

func (*BackupListingRequest) XXX_Size 

func (m *BackupListingRequest) XXX_Size() int

func (*BackupListingRequest) XXX_Unmarshal 

func (m *BackupListingRequest) XXX_Unmarshal(b []byte) error

type BackupListingResponse 

type BackupListingResponse struct {
	Entries              []*BackupListingResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*BackupListingResponse) Descriptor 

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

func (*BackupListingResponse) GetEntries 

func (m *BackupListingResponse) GetEntries() []*BackupListingResponse_Entry

func (*BackupListingResponse) ProtoMessage 

func (*BackupListingResponse) ProtoMessage()

func (*BackupListingResponse) Reset 

func (m *BackupListingResponse) Reset()

func (*BackupListingResponse) String 

func (m *BackupListingResponse) String() string

func (*BackupListingResponse) XXX_DiscardUnknown 

func (m *BackupListingResponse) XXX_DiscardUnknown()

func (*BackupListingResponse) XXX_Marshal 

func (m *BackupListingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupListingResponse) XXX_Merge 

func (m *BackupListingResponse) XXX_Merge(src proto.Message)

func (*BackupListingResponse) XXX_Size 

func (m *BackupListingResponse) XXX_Size() int

func (*BackupListingResponse) XXX_Unmarshal 

func (m *BackupListingResponse) XXX_Unmarshal(b []byte) error

type BackupListingResponse_Entry 

type BackupListingResponse_Entry struct {
	ClusterId            string          `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	TargetIp             string          `protobuf:"bytes,2,opt,name=target_ip,json=targetIp,proto3" json:"target_ip,omitempty"`
	SnapshotId           string          `protobuf:"bytes,3,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	CreatedAt            uint64          `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            uint64          `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	BackupType           uint32          `protobuf:"varint,6,opt,name=backup_type,json=backupType,proto3" json:"backup_type,omitempty"`
	Status               OperationStatus `protobuf:"varint,7,opt,name=status,proto3,enum=rpc.OperationStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*BackupListingResponse_Entry) Descriptor 

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

func (*BackupListingResponse_Entry) GetBackupType 

func (m *BackupListingResponse_Entry) GetBackupType() uint32

func (*BackupListingResponse_Entry) GetClusterId 

func (m *BackupListingResponse_Entry) GetClusterId() string

func (*BackupListingResponse_Entry) GetCreatedAt 

func (m *BackupListingResponse_Entry) GetCreatedAt() uint64

func (*BackupListingResponse_Entry) GetSnapshotId 

func (m *BackupListingResponse_Entry) GetSnapshotId() string

func (*BackupListingResponse_Entry) GetStatus 

func (m *BackupListingResponse_Entry) GetStatus() OperationStatus

func (*BackupListingResponse_Entry) GetTargetIp 

func (m *BackupListingResponse_Entry) GetTargetIp() string

func (*BackupListingResponse_Entry) GetUpdatedAt 

func (m *BackupListingResponse_Entry) GetUpdatedAt() uint64

func (*BackupListingResponse_Entry) ProtoMessage 

func (*BackupListingResponse_Entry) ProtoMessage()

func (*BackupListingResponse_Entry) Reset 

func (m *BackupListingResponse_Entry) Reset()

func (*BackupListingResponse_Entry) String 

func (m *BackupListingResponse_Entry) String() string

func (*BackupListingResponse_Entry) XXX_DiscardUnknown 

func (m *BackupListingResponse_Entry) XXX_DiscardUnknown()

func (*BackupListingResponse_Entry) XXX_Marshal 

func (m *BackupListingResponse_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupListingResponse_Entry) XXX_Merge 

func (m *BackupListingResponse_Entry) XXX_Merge(src proto.Message)

func (*BackupListingResponse_Entry) XXX_Size 

func (m *BackupListingResponse_Entry) XXX_Size() int

func (*BackupListingResponse_Entry) XXX_Unmarshal 

func (m *BackupListingResponse_Entry) XXX_Unmarshal(b []byte) error

type BackupRequest 

type BackupRequest struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	TargetIps            []string `protobuf:"bytes,2,rep,name=target_ips,json=targetIps,proto3" json:"target_ips,omitempty"`
	SnapshotId           string   `protobuf:"bytes,3,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	BackupType           uint32   `protobuf:"varint,4,opt,name=backup_type,json=backupType,proto3" json:"backup_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupRequest) Descriptor 

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

func (*BackupRequest) GetBackupType 

func (m *BackupRequest) GetBackupType() uint32

func (*BackupRequest) GetClusterId 

func (m *BackupRequest) GetClusterId() string

func (*BackupRequest) GetSnapshotId 

func (m *BackupRequest) GetSnapshotId() string

func (*BackupRequest) GetTargetIps 

func (m *BackupRequest) GetTargetIps() []string

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) Reset 

func (m *BackupRequest) Reset()

func (*BackupRequest) String 

func (m *BackupRequest) String() string

func (*BackupRequest) XXX_DiscardUnknown 

func (m *BackupRequest) XXX_DiscardUnknown()

func (*BackupRequest) XXX_Marshal 

func (m *BackupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupRequest) XXX_Merge 

func (m *BackupRequest) XXX_Merge(src proto.Message)

func (*BackupRequest) XXX_Size 

func (m *BackupRequest) XXX_Size() int

func (*BackupRequest) XXX_Unmarshal 

func (m *BackupRequest) XXX_Unmarshal(b []byte) error

type BackupResponse 

type BackupResponse struct {
	Status               OperationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=rpc.OperationStatus" json:"status,omitempty"`
	ClusterId            string          `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	TargetIps            []string        `protobuf:"bytes,3,rep,name=target_ips,json=targetIps,proto3" json:"target_ips,omitempty"`
	SnapshotId           string          `protobuf:"bytes,4,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	CreatedAt            uint64          `protobuf:"varint,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	BackupType           uint32          `protobuf:"varint,6,opt,name=backup_type,json=backupType,proto3" json:"backup_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*BackupResponse) Descriptor 

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

func (*BackupResponse) GetBackupType 

func (m *BackupResponse) GetBackupType() uint32

func (*BackupResponse) GetClusterId 

func (m *BackupResponse) GetClusterId() string

func (*BackupResponse) GetCreatedAt 

func (m *BackupResponse) GetCreatedAt() uint64

func (*BackupResponse) GetSnapshotId 

func (m *BackupResponse) GetSnapshotId() string

func (*BackupResponse) GetStatus 

func (m *BackupResponse) GetStatus() OperationStatus

func (*BackupResponse) GetTargetIps 

func (m *BackupResponse) GetTargetIps() []string

func (*BackupResponse) ProtoMessage 

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) Reset 

func (m *BackupResponse) Reset()

func (*BackupResponse) String 

func (m *BackupResponse) String() string

func (*BackupResponse) XXX_DiscardUnknown 

func (m *BackupResponse) XXX_DiscardUnknown()

func (*BackupResponse) XXX_Marshal 

func (m *BackupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupResponse) XXX_Merge 

func (m *BackupResponse) XXX_Merge(src proto.Message)

func (*BackupResponse) XXX_Size 

func (m *BackupResponse) XXX_Size() int

func (*BackupResponse) XXX_Unmarshal 

func (m *BackupResponse) XXX_Unmarshal(b []byte) error

type CassyClient 

type CassyClient interface {
	RegisterCluster(ctx context.Context, in *ClusterRegistrationRequest, opts ...grpc.CallOption) (*ClusterRegistrationResponse, error)
	ListClusters(ctx context.Context, in *ClusterListingRequest, opts ...grpc.CallOption) (*ClusterListingResponse, error)
	ListBackups(ctx context.Context, in *BackupListingRequest, opts ...grpc.CallOption) (*BackupListingResponse, error)
	TakeBackup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (*BackupResponse, error)
	RestoreBackup(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*RestoreResponse, error)
	ListRestoreStatuses(ctx context.Context, in *RestoreStatusListingRequest, opts ...grpc.CallOption) (*RestoreStatusListingResponse, error)
}

CassyClient is the client API for Cassy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCassyClient 

func NewCassyClient(cc *grpc.ClientConn) CassyClient

type CassyServer 

type CassyServer interface {
	RegisterCluster(context.Context, *ClusterRegistrationRequest) (*ClusterRegistrationResponse, error)
	ListClusters(context.Context, *ClusterListingRequest) (*ClusterListingResponse, error)
	ListBackups(context.Context, *BackupListingRequest) (*BackupListingResponse, error)
	TakeBackup(context.Context, *BackupRequest) (*BackupResponse, error)
	RestoreBackup(context.Context, *RestoreRequest) (*RestoreResponse, error)
	ListRestoreStatuses(context.Context, *RestoreStatusListingRequest) (*RestoreStatusListingResponse, error)
}

CassyServer is the server API for Cassy service.

type ClusterListingRequest 

type ClusterListingRequest struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Limit                int32    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterListingRequest) Descriptor 

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

func (*ClusterListingRequest) GetClusterId 

func (m *ClusterListingRequest) GetClusterId() string

func (*ClusterListingRequest) GetLimit 

func (m *ClusterListingRequest) GetLimit() int32

func (*ClusterListingRequest) ProtoMessage 

func (*ClusterListingRequest) ProtoMessage()

func (*ClusterListingRequest) Reset 

func (m *ClusterListingRequest) Reset()

func (*ClusterListingRequest) String 

func (m *ClusterListingRequest) String() string

func (*ClusterListingRequest) XXX_DiscardUnknown 

func (m *ClusterListingRequest) XXX_DiscardUnknown()

func (*ClusterListingRequest) XXX_Marshal 

func (m *ClusterListingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterListingRequest) XXX_Merge 

func (m *ClusterListingRequest) XXX_Merge(src proto.Message)

func (*ClusterListingRequest) XXX_Size 

func (m *ClusterListingRequest) XXX_Size() int

func (*ClusterListingRequest) XXX_Unmarshal 

func (m *ClusterListingRequest) XXX_Unmarshal(b []byte) error

type ClusterListingResponse 

type ClusterListingResponse struct {
	Entries              []*ClusterListingResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ClusterListingResponse) Descriptor 

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

func (*ClusterListingResponse) GetEntries 

func (m *ClusterListingResponse) GetEntries() []*ClusterListingResponse_Entry

func (*ClusterListingResponse) ProtoMessage 

func (*ClusterListingResponse) ProtoMessage()

func (*ClusterListingResponse) Reset 

func (m *ClusterListingResponse) Reset()

func (*ClusterListingResponse) String 

func (m *ClusterListingResponse) String() string

func (*ClusterListingResponse) XXX_DiscardUnknown 

func (m *ClusterListingResponse) XXX_DiscardUnknown()

func (*ClusterListingResponse) XXX_Marshal 

func (m *ClusterListingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterListingResponse) XXX_Merge 

func (m *ClusterListingResponse) XXX_Merge(src proto.Message)

func (*ClusterListingResponse) XXX_Size 

func (m *ClusterListingResponse) XXX_Size() int

func (*ClusterListingResponse) XXX_Unmarshal 

func (m *ClusterListingResponse) XXX_Unmarshal(b []byte) error

type ClusterListingResponse_Entry 

type ClusterListingResponse_Entry struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ClusterName          string   `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	TargetIps            []string `protobuf:"bytes,3,rep,name=target_ips,json=targetIps,proto3" json:"target_ips,omitempty"`
	Keyspaces            []string `protobuf:"bytes,4,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	DataDir              string   `protobuf:"bytes,5,opt,name=data_dir,json=dataDir,proto3" json:"data_dir,omitempty"`
	CreatedAt            uint64   `protobuf:"varint,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            uint64   `protobuf:"varint,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterListingResponse_Entry) Descriptor 

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

func (*ClusterListingResponse_Entry) GetClusterId 

func (m *ClusterListingResponse_Entry) GetClusterId() string

func (*ClusterListingResponse_Entry) GetClusterName 

func (m *ClusterListingResponse_Entry) GetClusterName() string

func (*ClusterListingResponse_Entry) GetCreatedAt 

func (m *ClusterListingResponse_Entry) GetCreatedAt() uint64

func (*ClusterListingResponse_Entry) GetDataDir 

func (m *ClusterListingResponse_Entry) GetDataDir() string

func (*ClusterListingResponse_Entry) GetKeyspaces 

func (m *ClusterListingResponse_Entry) GetKeyspaces() []string

func (*ClusterListingResponse_Entry) GetTargetIps 

func (m *ClusterListingResponse_Entry) GetTargetIps() []string

func (*ClusterListingResponse_Entry) GetUpdatedAt 

func (m *ClusterListingResponse_Entry) GetUpdatedAt() uint64

func (*ClusterListingResponse_Entry) ProtoMessage 

func (*ClusterListingResponse_Entry) ProtoMessage()

func (*ClusterListingResponse_Entry) Reset 

func (m *ClusterListingResponse_Entry) Reset()

func (*ClusterListingResponse_Entry) String 

func (m *ClusterListingResponse_Entry) String() string

func (*ClusterListingResponse_Entry) XXX_DiscardUnknown 

func (m *ClusterListingResponse_Entry) XXX_DiscardUnknown()

func (*ClusterListingResponse_Entry) XXX_Marshal 

func (m *ClusterListingResponse_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterListingResponse_Entry) XXX_Merge 

func (m *ClusterListingResponse_Entry) XXX_Merge(src proto.Message)

func (*ClusterListingResponse_Entry) XXX_Size 

func (m *ClusterListingResponse_Entry) XXX_Size() int

func (*ClusterListingResponse_Entry) XXX_Unmarshal 

func (m *ClusterListingResponse_Entry) XXX_Unmarshal(b []byte) error

type ClusterRegistrationRequest 

type ClusterRegistrationRequest struct {
	CassandraHost        string   `protobuf:"bytes,1,opt,name=cassandra_host,json=cassandraHost,proto3" json:"cassandra_host,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterRegistrationRequest) Descriptor 

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

func (*ClusterRegistrationRequest) GetCassandraHost 

func (m *ClusterRegistrationRequest) GetCassandraHost() string

func (*ClusterRegistrationRequest) ProtoMessage 

func (*ClusterRegistrationRequest) ProtoMessage()

func (*ClusterRegistrationRequest) Reset 

func (m *ClusterRegistrationRequest) Reset()

func (*ClusterRegistrationRequest) String 

func (m *ClusterRegistrationRequest) String() string

func (*ClusterRegistrationRequest) XXX_DiscardUnknown 

func (m *ClusterRegistrationRequest) XXX_DiscardUnknown()

func (*ClusterRegistrationRequest) XXX_Marshal 

func (m *ClusterRegistrationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterRegistrationRequest) XXX_Merge 

func (m *ClusterRegistrationRequest) XXX_Merge(src proto.Message)

func (*ClusterRegistrationRequest) XXX_Size 

func (m *ClusterRegistrationRequest) XXX_Size() int

func (*ClusterRegistrationRequest) XXX_Unmarshal 

func (m *ClusterRegistrationRequest) XXX_Unmarshal(b []byte) error

type ClusterRegistrationResponse 

type ClusterRegistrationResponse struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ClusterName          string   `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	TargetIps            []string `protobuf:"bytes,3,rep,name=target_ips,json=targetIps,proto3" json:"target_ips,omitempty"`
	Keyspaces            []string `protobuf:"bytes,4,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	DataDir              string   `protobuf:"bytes,5,opt,name=data_dir,json=dataDir,proto3" json:"data_dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterRegistrationResponse) Descriptor 

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

func (*ClusterRegistrationResponse) GetClusterId 

func (m *ClusterRegistrationResponse) GetClusterId() string

func (*ClusterRegistrationResponse) GetClusterName 

func (m *ClusterRegistrationResponse) GetClusterName() string

func (*ClusterRegistrationResponse) GetDataDir 

func (m *ClusterRegistrationResponse) GetDataDir() string

func (*ClusterRegistrationResponse) GetKeyspaces 

func (m *ClusterRegistrationResponse) GetKeyspaces() []string

func (*ClusterRegistrationResponse) GetTargetIps 

func (m *ClusterRegistrationResponse) GetTargetIps() []string

func (*ClusterRegistrationResponse) ProtoMessage 

func (*ClusterRegistrationResponse) ProtoMessage()

func (*ClusterRegistrationResponse) Reset 

func (m *ClusterRegistrationResponse) Reset()

func (*ClusterRegistrationResponse) String 

func (m *ClusterRegistrationResponse) String() string

func (*ClusterRegistrationResponse) XXX_DiscardUnknown 

func (m *ClusterRegistrationResponse) XXX_DiscardUnknown()

func (*ClusterRegistrationResponse) XXX_Marshal 

func (m *ClusterRegistrationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterRegistrationResponse) XXX_Merge 

func (m *ClusterRegistrationResponse) XXX_Merge(src proto.Message)

func (*ClusterRegistrationResponse) XXX_Size 

func (m *ClusterRegistrationResponse) XXX_Size() int

func (*ClusterRegistrationResponse) XXX_Unmarshal 

func (m *ClusterRegistrationResponse) XXX_Unmarshal(b []byte) error

type OperationStatus 

type OperationStatus int32
const (
	OperationStatus_UNKNOWN     OperationStatus = 0
	OperationStatus_INITIALIZED OperationStatus = 1
	OperationStatus_STARTED     OperationStatus = 2
	OperationStatus_COMPLETED   OperationStatus = 3
	OperationStatus_FAILED      OperationStatus = 4
)

func (OperationStatus) EnumDescriptor 

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

func (OperationStatus) String 

func (x OperationStatus) String() string

type PauseRequest 

type PauseRequest struct {
	WaitOutstanding      bool     `protobuf:"varint,1,opt,name=wait_outstanding,json=waitOutstanding,proto3" json:"wait_outstanding,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseRequest) Descriptor 

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

func (*PauseRequest) GetWaitOutstanding 

func (m *PauseRequest) GetWaitOutstanding() bool

func (*PauseRequest) ProtoMessage 

func (*PauseRequest) ProtoMessage()

func (*PauseRequest) Reset 

func (m *PauseRequest) Reset()

func (*PauseRequest) String 

func (m *PauseRequest) String() string

func (*PauseRequest) XXX_DiscardUnknown 

func (m *PauseRequest) XXX_DiscardUnknown()

func (*PauseRequest) XXX_Marshal 

func (m *PauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseRequest) XXX_Merge 

func (m *PauseRequest) XXX_Merge(src proto.Message)

func (*PauseRequest) XXX_Size 

func (m *PauseRequest) XXX_Size() int

func (*PauseRequest) XXX_Unmarshal 

func (m *PauseRequest) XXX_Unmarshal(b []byte) error

type RestoreRequest 

type RestoreRequest struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	TargetIps            []string `protobuf:"bytes,2,rep,name=target_ips,json=targetIps,proto3" json:"target_ips,omitempty"`
	SnapshotId           string   `protobuf:"bytes,3,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	RestoreType          uint32   `protobuf:"varint,4,opt,name=restore_type,json=restoreType,proto3" json:"restore_type,omitempty"`
	SnapshotOnly         bool     `protobuf:"varint,5,opt,name=snapshot_only,json=snapshotOnly,proto3" json:"snapshot_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestoreRequest) Descriptor 

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

func (*RestoreRequest) GetClusterId 

func (m *RestoreRequest) GetClusterId() string

func (*RestoreRequest) GetRestoreType 

func (m *RestoreRequest) GetRestoreType() uint32

func (*RestoreRequest) GetSnapshotId 

func (m *RestoreRequest) GetSnapshotId() string

func (*RestoreRequest) GetSnapshotOnly 

func (m *RestoreRequest) GetSnapshotOnly() bool

func (*RestoreRequest) GetTargetIps 

func (m *RestoreRequest) GetTargetIps() []string

func (*RestoreRequest) ProtoMessage 

func (*RestoreRequest) ProtoMessage()

func (*RestoreRequest) Reset 

func (m *RestoreRequest) Reset()

func (*RestoreRequest) String 

func (m *RestoreRequest) String() string

func (*RestoreRequest) XXX_DiscardUnknown 

func (m *RestoreRequest) XXX_DiscardUnknown()

func (*RestoreRequest) XXX_Marshal 

func (m *RestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreRequest) XXX_Merge 

func (m *RestoreRequest) XXX_Merge(src proto.Message)

func (*RestoreRequest) XXX_Size 

func (m *RestoreRequest) XXX_Size() int

func (*RestoreRequest) XXX_Unmarshal 

func (m *RestoreRequest) XXX_Unmarshal(b []byte) error

type RestoreResponse 

type RestoreResponse struct {
	Status               OperationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=rpc.OperationStatus" json:"status,omitempty"`
	ClusterId            string          `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	TargetIps            []string        `protobuf:"bytes,3,rep,name=target_ips,json=targetIps,proto3" json:"target_ips,omitempty"`
	SnapshotId           string          `protobuf:"bytes,4,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	RestoreType          uint32          `protobuf:"varint,5,opt,name=restore_type,json=restoreType,proto3" json:"restore_type,omitempty"`
	SnapshotOnly         bool            `protobuf:"varint,6,opt,name=snapshot_only,json=snapshotOnly,proto3" json:"snapshot_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RestoreResponse) Descriptor 

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

func (*RestoreResponse) GetClusterId 

func (m *RestoreResponse) GetClusterId() string

func (*RestoreResponse) GetRestoreType 

func (m *RestoreResponse) GetRestoreType() uint32

func (*RestoreResponse) GetSnapshotId 

func (m *RestoreResponse) GetSnapshotId() string

func (*RestoreResponse) GetSnapshotOnly 

func (m *RestoreResponse) GetSnapshotOnly() bool

func (*RestoreResponse) GetStatus 

func (m *RestoreResponse) GetStatus() OperationStatus

func (*RestoreResponse) GetTargetIps 

func (m *RestoreResponse) GetTargetIps() []string

func (*RestoreResponse) ProtoMessage 

func (*RestoreResponse) ProtoMessage()

func (*RestoreResponse) Reset 

func (m *RestoreResponse) Reset()

func (*RestoreResponse) String 

func (m *RestoreResponse) String() string

func (*RestoreResponse) XXX_DiscardUnknown 

func (m *RestoreResponse) XXX_DiscardUnknown()

func (*RestoreResponse) XXX_Marshal 

func (m *RestoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreResponse) XXX_Merge 

func (m *RestoreResponse) XXX_Merge(src proto.Message)

func (*RestoreResponse) XXX_Size 

func (m *RestoreResponse) XXX_Size() int

func (*RestoreResponse) XXX_Unmarshal 

func (m *RestoreResponse) XXX_Unmarshal(b []byte) error

type RestoreStatusListingRequest 

type RestoreStatusListingRequest struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	TargetIp             string   `protobuf:"bytes,2,opt,name=target_ip,json=targetIp,proto3" json:"target_ip,omitempty"`
	SnapshotId           string   `protobuf:"bytes,3,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	Limit                int32    `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestoreStatusListingRequest) Descriptor 

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

func (*RestoreStatusListingRequest) GetClusterId 

func (m *RestoreStatusListingRequest) GetClusterId() string

func (*RestoreStatusListingRequest) GetLimit 

func (m *RestoreStatusListingRequest) GetLimit() int32

func (*RestoreStatusListingRequest) GetSnapshotId 

func (m *RestoreStatusListingRequest) GetSnapshotId() string

func (*RestoreStatusListingRequest) GetTargetIp 

func (m *RestoreStatusListingRequest) GetTargetIp() string

func (*RestoreStatusListingRequest) ProtoMessage 

func (*RestoreStatusListingRequest) ProtoMessage()

func (*RestoreStatusListingRequest) Reset 

func (m *RestoreStatusListingRequest) Reset()

func (*RestoreStatusListingRequest) String 

func (m *RestoreStatusListingRequest) String() string

func (*RestoreStatusListingRequest) XXX_DiscardUnknown 

func (m *RestoreStatusListingRequest) XXX_DiscardUnknown()

func (*RestoreStatusListingRequest) XXX_Marshal 

func (m *RestoreStatusListingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreStatusListingRequest) XXX_Merge 

func (m *RestoreStatusListingRequest) XXX_Merge(src proto.Message)

func (*RestoreStatusListingRequest) XXX_Size 

func (m *RestoreStatusListingRequest) XXX_Size() int

func (*RestoreStatusListingRequest) XXX_Unmarshal 

func (m *RestoreStatusListingRequest) XXX_Unmarshal(b []byte) error

type RestoreStatusListingResponse 

type RestoreStatusListingResponse struct {
	ClusterId            string                                `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Entries              []*RestoreStatusListingResponse_Entry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*RestoreStatusListingResponse) Descriptor 

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

func (*RestoreStatusListingResponse) GetClusterId 

func (m *RestoreStatusListingResponse) GetClusterId() string

func (*RestoreStatusListingResponse) GetEntries 

func (m *RestoreStatusListingResponse) GetEntries() []*RestoreStatusListingResponse_Entry

func (*RestoreStatusListingResponse) ProtoMessage 

func (*RestoreStatusListingResponse) ProtoMessage()

func (*RestoreStatusListingResponse) Reset 

func (m *RestoreStatusListingResponse) Reset()

func (*RestoreStatusListingResponse) String 

func (m *RestoreStatusListingResponse) String() string

func (*RestoreStatusListingResponse) XXX_DiscardUnknown 

func (m *RestoreStatusListingResponse) XXX_DiscardUnknown()

func (*RestoreStatusListingResponse) XXX_Marshal 

func (m *RestoreStatusListingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreStatusListingResponse) XXX_Merge 

func (m *RestoreStatusListingResponse) XXX_Merge(src proto.Message)

func (*RestoreStatusListingResponse) XXX_Size 

func (m *RestoreStatusListingResponse) XXX_Size() int

func (*RestoreStatusListingResponse) XXX_Unmarshal 

func (m *RestoreStatusListingResponse) XXX_Unmarshal(b []byte) error

type RestoreStatusListingResponse_Entry 

type RestoreStatusListingResponse_Entry struct {
	TargetIp             string          `protobuf:"bytes,1,opt,name=target_ip,json=targetIp,proto3" json:"target_ip,omitempty"`
	SnapshotId           string          `protobuf:"bytes,2,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	CreatedAt            uint64          `protobuf:"varint,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            uint64          `protobuf:"varint,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	RestoreType          uint32          `protobuf:"varint,5,opt,name=restore_type,json=restoreType,proto3" json:"restore_type,omitempty"`
	Status               OperationStatus `protobuf:"varint,6,opt,name=status,proto3,enum=rpc.OperationStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RestoreStatusListingResponse_Entry) Descriptor 

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

func (*RestoreStatusListingResponse_Entry) GetCreatedAt 

func (m *RestoreStatusListingResponse_Entry) GetCreatedAt() uint64

func (*RestoreStatusListingResponse_Entry) GetRestoreType 

func (m *RestoreStatusListingResponse_Entry) GetRestoreType() uint32

func (*RestoreStatusListingResponse_Entry) GetSnapshotId 

func (m *RestoreStatusListingResponse_Entry) GetSnapshotId() string

func (*RestoreStatusListingResponse_Entry) GetStatus 

func (m *RestoreStatusListingResponse_Entry) GetStatus() OperationStatus

func (*RestoreStatusListingResponse_Entry) GetTargetIp 

func (m *RestoreStatusListingResponse_Entry) GetTargetIp() string

func (*RestoreStatusListingResponse_Entry) GetUpdatedAt 

func (m *RestoreStatusListingResponse_Entry) GetUpdatedAt() uint64

func (*RestoreStatusListingResponse_Entry) ProtoMessage 

func (*RestoreStatusListingResponse_Entry) ProtoMessage()

func (*RestoreStatusListingResponse_Entry) Reset 

func (m *RestoreStatusListingResponse_Entry) Reset()

func (*RestoreStatusListingResponse_Entry) String 

func (m *RestoreStatusListingResponse_Entry) String() string

func (*RestoreStatusListingResponse_Entry) XXX_DiscardUnknown 

func (m *RestoreStatusListingResponse_Entry) XXX_DiscardUnknown()

func (*RestoreStatusListingResponse_Entry) XXX_Marshal 

func (m *RestoreStatusListingResponse_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreStatusListingResponse_Entry) XXX_Merge 

func (m *RestoreStatusListingResponse_Entry) XXX_Merge(src proto.Message)

func (*RestoreStatusListingResponse_Entry) XXX_Size 

func (m *RestoreStatusListingResponse_Entry) XXX_Size() int

func (*RestoreStatusListingResponse_Entry) XXX_Unmarshal 

func (m *RestoreStatusListingResponse_Entry) XXX_Unmarshal(b []byte) error

type StatsResponse 

type StatsResponse struct {
	Stats                string   `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatsResponse) Descriptor 

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

func (*StatsResponse) GetStats 

func (m *StatsResponse) GetStats() string

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) Reset 

func (m *StatsResponse) Reset()

func (*StatsResponse) String 

func (m *StatsResponse) String() string

func (*StatsResponse) XXX_DiscardUnknown 

func (m *StatsResponse) XXX_DiscardUnknown()

func (*StatsResponse) XXX_Marshal 

func (m *StatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatsResponse) XXX_Merge 

func (m *StatsResponse) XXX_Merge(src proto.Message)

func (*StatsResponse) XXX_Size 

func (m *StatsResponse) XXX_Size() int

func (*StatsResponse) XXX_Unmarshal 

func (m *StatsResponse) XXX_Unmarshal(b []byte) error

type UnimplementedAdminServer 

type UnimplementedAdminServer struct {
}

UnimplementedAdminServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServer) Pause 

func (*UnimplementedAdminServer) Pause(ctx context.Context, req *PauseRequest) (*empty.Empty, error)

func (*UnimplementedAdminServer) Stats 

func (*UnimplementedAdminServer) Stats(ctx context.Context, req *empty.Empty) (*StatsResponse, error)

func (*UnimplementedAdminServer) Unpause 

func (*UnimplementedAdminServer) Unpause(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

type UnimplementedCassyServer 

type UnimplementedCassyServer struct {
}

UnimplementedCassyServer can be embedded to have forward compatible implementations.

func (*UnimplementedCassyServer) ListBackups 

func (*UnimplementedCassyServer) ListBackups(ctx context.Context, req *BackupListingRequest) (*BackupListingResponse, error)

func (*UnimplementedCassyServer) ListClusters 

func (*UnimplementedCassyServer) ListClusters(ctx context.Context, req *ClusterListingRequest) (*ClusterListingResponse, error)

func (*UnimplementedCassyServer) ListRestoreStatuses 

func (*UnimplementedCassyServer) ListRestoreStatuses(ctx context.Context, req *RestoreStatusListingRequest) (*RestoreStatusListingResponse, error)

func (*UnimplementedCassyServer) RegisterCluster 

func (*UnimplementedCassyServer) RegisterCluster(ctx context.Context, req *ClusterRegistrationRequest) (*ClusterRegistrationResponse, error)

func (*UnimplementedCassyServer) RestoreBackup 

func (*UnimplementedCassyServer) RestoreBackup(ctx context.Context, req *RestoreRequest) (*RestoreResponse, error)

func (*UnimplementedCassyServer) TakeBackup 

func (*UnimplementedCassyServer) TakeBackup(ctx context.Context, req *BackupRequest) (*BackupResponse, error)

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.