wire

package
v0.0.0-...-810cf82 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2019 License: MIT Imports: 7 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterControlServer 

func RegisterControlServer(s *grpc.Server, srv ControlServer)

Types

type ControlClient 

type ControlClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	PublicKeyGet(ctx context.Context, in *PublicKeyGetRequest, opts ...grpc.CallOption) (*PublicKeyGetResponse, error)
	VolumeCreate(ctx context.Context, in *VolumeCreateRequest, opts ...grpc.CallOption) (*VolumeCreateResponse, error)
	VolumeConnect(ctx context.Context, in *VolumeConnectRequest, opts ...grpc.CallOption) (*VolumeConnectResponse, error)
	VolumeMount(ctx context.Context, in *VolumeMountRequest, opts ...grpc.CallOption) (*VolumeMountResponse, error)
	VolumeStorageAdd(ctx context.Context, in *VolumeStorageAddRequest, opts ...grpc.CallOption) (*VolumeStorageAddResponse, error)
	VolumeSync(ctx context.Context, in *VolumeSyncRequest, opts ...grpc.CallOption) (*VolumeSyncResponse, error)
	SharingKeyAdd(ctx context.Context, in *SharingKeyAddRequest, opts ...grpc.CallOption) (*SharingKeyAddResponse, error)
	PeerAdd(ctx context.Context, in *PeerAddRequest, opts ...grpc.CallOption) (*PeerAddResponse, error)
	PeerLocationSet(ctx context.Context, in *PeerLocationSetRequest, opts ...grpc.CallOption) (*PeerLocationSetResponse, error)
	PeerStorageAllow(ctx context.Context, in *PeerStorageAllowRequest, opts ...grpc.CallOption) (*PeerStorageAllowResponse, error)
	PeerVolumeAllow(ctx context.Context, in *PeerVolumeAllowRequest, opts ...grpc.CallOption) (*PeerVolumeAllowResponse, error)
}

ControlClient is the client API for Control service.

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

func NewControlClient 

func NewControlClient(cc *grpc.ClientConn) ControlClient

type ControlServer 

type ControlServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	PublicKeyGet(context.Context, *PublicKeyGetRequest) (*PublicKeyGetResponse, error)
	VolumeCreate(context.Context, *VolumeCreateRequest) (*VolumeCreateResponse, error)
	VolumeConnect(context.Context, *VolumeConnectRequest) (*VolumeConnectResponse, error)
	VolumeMount(context.Context, *VolumeMountRequest) (*VolumeMountResponse, error)
	VolumeStorageAdd(context.Context, *VolumeStorageAddRequest) (*VolumeStorageAddResponse, error)
	VolumeSync(context.Context, *VolumeSyncRequest) (*VolumeSyncResponse, error)
	SharingKeyAdd(context.Context, *SharingKeyAddRequest) (*SharingKeyAddResponse, error)
	PeerAdd(context.Context, *PeerAddRequest) (*PeerAddResponse, error)
	PeerLocationSet(context.Context, *PeerLocationSetRequest) (*PeerLocationSetResponse, error)
	PeerStorageAllow(context.Context, *PeerStorageAllowRequest) (*PeerStorageAllowResponse, error)
	PeerVolumeAllow(context.Context, *PeerVolumeAllowRequest) (*PeerVolumeAllowResponse, error)
}

ControlServer is the server API for Control service.

type PeerAddRequest 

type PeerAddRequest struct {
	// Must be exactly 32 bytes long.
	Pub                  []byte   `protobuf:"bytes,2,opt,name=pub,proto3" json:"pub,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerAddRequest) Descriptor 

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

func (*PeerAddRequest) GetPub 

func (m *PeerAddRequest) GetPub() []byte

func (*PeerAddRequest) ProtoMessage 

func (*PeerAddRequest) ProtoMessage()

func (*PeerAddRequest) Reset 

func (m *PeerAddRequest) Reset()

func (*PeerAddRequest) String 

func (m *PeerAddRequest) String() string

func (*PeerAddRequest) XXX_DiscardUnknown 

func (m *PeerAddRequest) XXX_DiscardUnknown()

func (*PeerAddRequest) XXX_Marshal 

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

func (*PeerAddRequest) XXX_Merge 

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

func (*PeerAddRequest) XXX_Size 

func (m *PeerAddRequest) XXX_Size() int

func (*PeerAddRequest) XXX_Unmarshal 

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

type PeerAddResponse 

type PeerAddResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerAddResponse) Descriptor 

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

func (*PeerAddResponse) ProtoMessage 

func (*PeerAddResponse) ProtoMessage()

func (*PeerAddResponse) Reset 

func (m *PeerAddResponse) Reset()

func (*PeerAddResponse) String 

func (m *PeerAddResponse) String() string

func (*PeerAddResponse) XXX_DiscardUnknown 

func (m *PeerAddResponse) XXX_DiscardUnknown()

func (*PeerAddResponse) XXX_Marshal 

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

func (*PeerAddResponse) XXX_Merge 

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

func (*PeerAddResponse) XXX_Size 

func (m *PeerAddResponse) XXX_Size() int

func (*PeerAddResponse) XXX_Unmarshal 

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

type PeerLocationSetRequest 

type PeerLocationSetRequest struct {
	// Must be exactly 32 bytes long.
	Pub                  []byte   `protobuf:"bytes,1,opt,name=pub,proto3" json:"pub,omitempty"`
	Netloc               string   `protobuf:"bytes,2,opt,name=netloc,proto3" json:"netloc,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerLocationSetRequest) Descriptor 

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

func (*PeerLocationSetRequest) GetNetloc 

func (m *PeerLocationSetRequest) GetNetloc() string

func (*PeerLocationSetRequest) GetPub 

func (m *PeerLocationSetRequest) GetPub() []byte

func (*PeerLocationSetRequest) ProtoMessage 

func (*PeerLocationSetRequest) ProtoMessage()

func (*PeerLocationSetRequest) Reset 

func (m *PeerLocationSetRequest) Reset()

func (*PeerLocationSetRequest) String 

func (m *PeerLocationSetRequest) String() string

func (*PeerLocationSetRequest) XXX_DiscardUnknown 

func (m *PeerLocationSetRequest) XXX_DiscardUnknown()

func (*PeerLocationSetRequest) XXX_Marshal 

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

func (*PeerLocationSetRequest) XXX_Merge 

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

func (*PeerLocationSetRequest) XXX_Size 

func (m *PeerLocationSetRequest) XXX_Size() int

func (*PeerLocationSetRequest) XXX_Unmarshal 

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

type PeerLocationSetResponse 

type PeerLocationSetResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerLocationSetResponse) Descriptor 

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

func (*PeerLocationSetResponse) ProtoMessage 

func (*PeerLocationSetResponse) ProtoMessage()

func (*PeerLocationSetResponse) Reset 

func (m *PeerLocationSetResponse) Reset()

func (*PeerLocationSetResponse) String 

func (m *PeerLocationSetResponse) String() string

func (*PeerLocationSetResponse) XXX_DiscardUnknown 

func (m *PeerLocationSetResponse) XXX_DiscardUnknown()

func (*PeerLocationSetResponse) XXX_Marshal 

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

func (*PeerLocationSetResponse) XXX_Merge 

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

func (*PeerLocationSetResponse) XXX_Size 

func (m *PeerLocationSetResponse) XXX_Size() int

func (*PeerLocationSetResponse) XXX_Unmarshal 

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

type PeerStorageAllowRequest 

type PeerStorageAllowRequest struct {
	// Must be exactly 32 bytes long.
	Pub                  []byte   `protobuf:"bytes,1,opt,name=pub,proto3" json:"pub,omitempty"`
	Backend              string   `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerStorageAllowRequest) Descriptor 

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

func (*PeerStorageAllowRequest) GetBackend 

func (m *PeerStorageAllowRequest) GetBackend() string

func (*PeerStorageAllowRequest) GetPub 

func (m *PeerStorageAllowRequest) GetPub() []byte

func (*PeerStorageAllowRequest) ProtoMessage 

func (*PeerStorageAllowRequest) ProtoMessage()

func (*PeerStorageAllowRequest) Reset 

func (m *PeerStorageAllowRequest) Reset()

func (*PeerStorageAllowRequest) String 

func (m *PeerStorageAllowRequest) String() string

func (*PeerStorageAllowRequest) XXX_DiscardUnknown 

func (m *PeerStorageAllowRequest) XXX_DiscardUnknown()

func (*PeerStorageAllowRequest) XXX_Marshal 

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

func (*PeerStorageAllowRequest) XXX_Merge 

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

func (*PeerStorageAllowRequest) XXX_Size 

func (m *PeerStorageAllowRequest) XXX_Size() int

func (*PeerStorageAllowRequest) XXX_Unmarshal 

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

type PeerStorageAllowResponse 

type PeerStorageAllowResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerStorageAllowResponse) Descriptor 

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

func (*PeerStorageAllowResponse) ProtoMessage 

func (*PeerStorageAllowResponse) ProtoMessage()

func (*PeerStorageAllowResponse) Reset 

func (m *PeerStorageAllowResponse) Reset()

func (*PeerStorageAllowResponse) String 

func (m *PeerStorageAllowResponse) String() string

func (*PeerStorageAllowResponse) XXX_DiscardUnknown 

func (m *PeerStorageAllowResponse) XXX_DiscardUnknown()

func (*PeerStorageAllowResponse) XXX_Marshal 

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

func (*PeerStorageAllowResponse) XXX_Merge 

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

func (*PeerStorageAllowResponse) XXX_Size 

func (m *PeerStorageAllowResponse) XXX_Size() int

func (*PeerStorageAllowResponse) XXX_Unmarshal 

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

type PeerVolumeAllowRequest 

type PeerVolumeAllowRequest struct {
	// Must be exactly 32 bytes long.
	Pub                  []byte   `protobuf:"bytes,1,opt,name=pub,proto3" json:"pub,omitempty"`
	VolumeName           string   `protobuf:"bytes,2,opt,name=volumeName,proto3" json:"volumeName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerVolumeAllowRequest) Descriptor 

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

func (*PeerVolumeAllowRequest) GetPub 

func (m *PeerVolumeAllowRequest) GetPub() []byte

func (*PeerVolumeAllowRequest) GetVolumeName 

func (m *PeerVolumeAllowRequest) GetVolumeName() string

func (*PeerVolumeAllowRequest) ProtoMessage 

func (*PeerVolumeAllowRequest) ProtoMessage()

func (*PeerVolumeAllowRequest) Reset 

func (m *PeerVolumeAllowRequest) Reset()

func (*PeerVolumeAllowRequest) String 

func (m *PeerVolumeAllowRequest) String() string

func (*PeerVolumeAllowRequest) XXX_DiscardUnknown 

func (m *PeerVolumeAllowRequest) XXX_DiscardUnknown()

func (*PeerVolumeAllowRequest) XXX_Marshal 

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

func (*PeerVolumeAllowRequest) XXX_Merge 

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

func (*PeerVolumeAllowRequest) XXX_Size 

func (m *PeerVolumeAllowRequest) XXX_Size() int

func (*PeerVolumeAllowRequest) XXX_Unmarshal 

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

type PeerVolumeAllowResponse 

type PeerVolumeAllowResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerVolumeAllowResponse) Descriptor 

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

func (*PeerVolumeAllowResponse) ProtoMessage 

func (*PeerVolumeAllowResponse) ProtoMessage()

func (*PeerVolumeAllowResponse) Reset 

func (m *PeerVolumeAllowResponse) Reset()

func (*PeerVolumeAllowResponse) String 

func (m *PeerVolumeAllowResponse) String() string

func (*PeerVolumeAllowResponse) XXX_DiscardUnknown 

func (m *PeerVolumeAllowResponse) XXX_DiscardUnknown()

func (*PeerVolumeAllowResponse) XXX_Marshal 

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

func (*PeerVolumeAllowResponse) XXX_Merge 

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

func (*PeerVolumeAllowResponse) XXX_Size 

func (m *PeerVolumeAllowResponse) XXX_Size() int

func (*PeerVolumeAllowResponse) XXX_Unmarshal 

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

type PingRequest 

type PingRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingRequest) Descriptor 

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

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset 

func (m *PingRequest) Reset()

func (*PingRequest) String 

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal 

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

func (*PingRequest) XXX_Merge 

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

func (*PingRequest) XXX_Size 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal 

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

type PingResponse 

type PingResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingResponse) Descriptor 

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

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset 

func (m *PingResponse) Reset()

func (*PingResponse) String 

func (m *PingResponse) String() string

func (*PingResponse) XXX_DiscardUnknown 

func (m *PingResponse) XXX_DiscardUnknown()

func (*PingResponse) XXX_Marshal 

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

func (*PingResponse) XXX_Merge 

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

func (*PingResponse) XXX_Size 

func (m *PingResponse) XXX_Size() int

func (*PingResponse) XXX_Unmarshal 

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

type PublicKeyGetRequest 

type PublicKeyGetRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublicKeyGetRequest) Descriptor 

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

func (*PublicKeyGetRequest) ProtoMessage 

func (*PublicKeyGetRequest) ProtoMessage()

func (*PublicKeyGetRequest) Reset 

func (m *PublicKeyGetRequest) Reset()

func (*PublicKeyGetRequest) String 

func (m *PublicKeyGetRequest) String() string

func (*PublicKeyGetRequest) XXX_DiscardUnknown 

func (m *PublicKeyGetRequest) XXX_DiscardUnknown()

func (*PublicKeyGetRequest) XXX_Marshal 

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

func (*PublicKeyGetRequest) XXX_Merge 

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

func (*PublicKeyGetRequest) XXX_Size 

func (m *PublicKeyGetRequest) XXX_Size() int

func (*PublicKeyGetRequest) XXX_Unmarshal 

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

type PublicKeyGetResponse 

type PublicKeyGetResponse struct {
	// Exactly 32 bytes long.
	Pub                  []byte   `protobuf:"bytes,1,opt,name=pub,proto3" json:"pub,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublicKeyGetResponse) Descriptor 

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

func (*PublicKeyGetResponse) GetPub 

func (m *PublicKeyGetResponse) GetPub() []byte

func (*PublicKeyGetResponse) ProtoMessage 

func (*PublicKeyGetResponse) ProtoMessage()

func (*PublicKeyGetResponse) Reset 

func (m *PublicKeyGetResponse) Reset()

func (*PublicKeyGetResponse) String 

func (m *PublicKeyGetResponse) String() string

func (*PublicKeyGetResponse) XXX_DiscardUnknown 

func (m *PublicKeyGetResponse) XXX_DiscardUnknown()

func (*PublicKeyGetResponse) XXX_Marshal 

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

func (*PublicKeyGetResponse) XXX_Merge 

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

func (*PublicKeyGetResponse) XXX_Size 

func (m *PublicKeyGetResponse) XXX_Size() int

func (*PublicKeyGetResponse) XXX_Unmarshal 

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

type SharingKeyAddRequest 

type SharingKeyAddRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Must be exactly 32 bytes long.
	Secret               []byte   `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SharingKeyAddRequest) Descriptor 

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

func (*SharingKeyAddRequest) GetName 

func (m *SharingKeyAddRequest) GetName() string

func (*SharingKeyAddRequest) GetSecret 

func (m *SharingKeyAddRequest) GetSecret() []byte

func (*SharingKeyAddRequest) ProtoMessage 

func (*SharingKeyAddRequest) ProtoMessage()

func (*SharingKeyAddRequest) Reset 

func (m *SharingKeyAddRequest) Reset()

func (*SharingKeyAddRequest) String 

func (m *SharingKeyAddRequest) String() string

func (*SharingKeyAddRequest) XXX_DiscardUnknown 

func (m *SharingKeyAddRequest) XXX_DiscardUnknown()

func (*SharingKeyAddRequest) XXX_Marshal 

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

func (*SharingKeyAddRequest) XXX_Merge 

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

func (*SharingKeyAddRequest) XXX_Size 

func (m *SharingKeyAddRequest) XXX_Size() int

func (*SharingKeyAddRequest) XXX_Unmarshal 

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

type SharingKeyAddResponse 

type SharingKeyAddResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SharingKeyAddResponse) Descriptor 

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

func (*SharingKeyAddResponse) ProtoMessage 

func (*SharingKeyAddResponse) ProtoMessage()

func (*SharingKeyAddResponse) Reset 

func (m *SharingKeyAddResponse) Reset()

func (*SharingKeyAddResponse) String 

func (m *SharingKeyAddResponse) String() string

func (*SharingKeyAddResponse) XXX_DiscardUnknown 

func (m *SharingKeyAddResponse) XXX_DiscardUnknown()

func (*SharingKeyAddResponse) XXX_Marshal 

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

func (*SharingKeyAddResponse) XXX_Merge 

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

func (*SharingKeyAddResponse) XXX_Size 

func (m *SharingKeyAddResponse) XXX_Size() int

func (*SharingKeyAddResponse) XXX_Unmarshal 

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

type UnimplementedControlServer 

type UnimplementedControlServer struct {
}

UnimplementedControlServer can be embedded to have forward compatible implementations.

func (*UnimplementedControlServer) PeerAdd 

func (*UnimplementedControlServer) PeerAdd(ctx context.Context, req *PeerAddRequest) (*PeerAddResponse, error)

func (*UnimplementedControlServer) PeerLocationSet 

func (*UnimplementedControlServer) PeerLocationSet(ctx context.Context, req *PeerLocationSetRequest) (*PeerLocationSetResponse, error)

func (*UnimplementedControlServer) PeerStorageAllow 

func (*UnimplementedControlServer) PeerStorageAllow(ctx context.Context, req *PeerStorageAllowRequest) (*PeerStorageAllowResponse, error)

func (*UnimplementedControlServer) PeerVolumeAllow 

func (*UnimplementedControlServer) PeerVolumeAllow(ctx context.Context, req *PeerVolumeAllowRequest) (*PeerVolumeAllowResponse, error)

func (*UnimplementedControlServer) Ping 

func (*UnimplementedControlServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error)

func (*UnimplementedControlServer) PublicKeyGet 

func (*UnimplementedControlServer) PublicKeyGet(ctx context.Context, req *PublicKeyGetRequest) (*PublicKeyGetResponse, error)

func (*UnimplementedControlServer) SharingKeyAdd 

func (*UnimplementedControlServer) SharingKeyAdd(ctx context.Context, req *SharingKeyAddRequest) (*SharingKeyAddResponse, error)

func (*UnimplementedControlServer) VolumeConnect 

func (*UnimplementedControlServer) VolumeConnect(ctx context.Context, req *VolumeConnectRequest) (*VolumeConnectResponse, error)

func (*UnimplementedControlServer) VolumeCreate 

func (*UnimplementedControlServer) VolumeCreate(ctx context.Context, req *VolumeCreateRequest) (*VolumeCreateResponse, error)

func (*UnimplementedControlServer) VolumeMount 

func (*UnimplementedControlServer) VolumeMount(ctx context.Context, req *VolumeMountRequest) (*VolumeMountResponse, error)

func (*UnimplementedControlServer) VolumeStorageAdd 

func (*UnimplementedControlServer) VolumeStorageAdd(ctx context.Context, req *VolumeStorageAddRequest) (*VolumeStorageAddResponse, error)

func (*UnimplementedControlServer) VolumeSync 

func (*UnimplementedControlServer) VolumeSync(ctx context.Context, req *VolumeSyncRequest) (*VolumeSyncResponse, error)

type VolumeConnectRequest 

type VolumeConnectRequest struct {
	// Must be exactly 32 bytes long.
	Pub                  []byte   `protobuf:"bytes,1,opt,name=pub,proto3" json:"pub,omitempty"`
	VolumeName           string   `protobuf:"bytes,2,opt,name=volumeName,proto3" json:"volumeName,omitempty"`
	LocalVolumeName      string   `protobuf:"bytes,3,opt,name=localVolumeName,proto3" json:"localVolumeName,omitempty"`
	Backend              string   `protobuf:"bytes,4,opt,name=backend,proto3" json:"backend,omitempty"`
	SharingKeyName       string   `protobuf:"bytes,5,opt,name=sharingKeyName,proto3" json:"sharingKeyName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeConnectRequest) Descriptor 

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

func (*VolumeConnectRequest) GetBackend 

func (m *VolumeConnectRequest) GetBackend() string

func (*VolumeConnectRequest) GetLocalVolumeName 

func (m *VolumeConnectRequest) GetLocalVolumeName() string

func (*VolumeConnectRequest) GetPub 

func (m *VolumeConnectRequest) GetPub() []byte

func (*VolumeConnectRequest) GetSharingKeyName 

func (m *VolumeConnectRequest) GetSharingKeyName() string

func (*VolumeConnectRequest) GetVolumeName 

func (m *VolumeConnectRequest) GetVolumeName() string

func (*VolumeConnectRequest) ProtoMessage 

func (*VolumeConnectRequest) ProtoMessage()

func (*VolumeConnectRequest) Reset 

func (m *VolumeConnectRequest) Reset()

func (*VolumeConnectRequest) String 

func (m *VolumeConnectRequest) String() string

func (*VolumeConnectRequest) XXX_DiscardUnknown 

func (m *VolumeConnectRequest) XXX_DiscardUnknown()

func (*VolumeConnectRequest) XXX_Marshal 

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

func (*VolumeConnectRequest) XXX_Merge 

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

func (*VolumeConnectRequest) XXX_Size 

func (m *VolumeConnectRequest) XXX_Size() int

func (*VolumeConnectRequest) XXX_Unmarshal 

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

type VolumeConnectResponse 

type VolumeConnectResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeConnectResponse) Descriptor 

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

func (*VolumeConnectResponse) ProtoMessage 

func (*VolumeConnectResponse) ProtoMessage()

func (*VolumeConnectResponse) Reset 

func (m *VolumeConnectResponse) Reset()

func (*VolumeConnectResponse) String 

func (m *VolumeConnectResponse) String() string

func (*VolumeConnectResponse) XXX_DiscardUnknown 

func (m *VolumeConnectResponse) XXX_DiscardUnknown()

func (*VolumeConnectResponse) XXX_Marshal 

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

func (*VolumeConnectResponse) XXX_Merge 

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

func (*VolumeConnectResponse) XXX_Size 

func (m *VolumeConnectResponse) XXX_Size() int

func (*VolumeConnectResponse) XXX_Unmarshal 

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

type VolumeCreateRequest 

type VolumeCreateRequest struct {
	VolumeName           string   `protobuf:"bytes,1,opt,name=volumeName,proto3" json:"volumeName,omitempty"`
	Backend              string   `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	SharingKeyName       string   `protobuf:"bytes,3,opt,name=sharingKeyName,proto3" json:"sharingKeyName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeCreateRequest) Descriptor 

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

func (*VolumeCreateRequest) GetBackend 

func (m *VolumeCreateRequest) GetBackend() string

func (*VolumeCreateRequest) GetSharingKeyName 

func (m *VolumeCreateRequest) GetSharingKeyName() string

func (*VolumeCreateRequest) GetVolumeName 

func (m *VolumeCreateRequest) GetVolumeName() string

func (*VolumeCreateRequest) ProtoMessage 

func (*VolumeCreateRequest) ProtoMessage()

func (*VolumeCreateRequest) Reset 

func (m *VolumeCreateRequest) Reset()

func (*VolumeCreateRequest) String 

func (m *VolumeCreateRequest) String() string

func (*VolumeCreateRequest) XXX_DiscardUnknown 

func (m *VolumeCreateRequest) XXX_DiscardUnknown()

func (*VolumeCreateRequest) XXX_Marshal 

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

func (*VolumeCreateRequest) XXX_Merge 

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

func (*VolumeCreateRequest) XXX_Size 

func (m *VolumeCreateRequest) XXX_Size() int

func (*VolumeCreateRequest) XXX_Unmarshal 

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

type VolumeCreateResponse 

type VolumeCreateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeCreateResponse) Descriptor 

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

func (*VolumeCreateResponse) ProtoMessage 

func (*VolumeCreateResponse) ProtoMessage()

func (*VolumeCreateResponse) Reset 

func (m *VolumeCreateResponse) Reset()

func (*VolumeCreateResponse) String 

func (m *VolumeCreateResponse) String() string

func (*VolumeCreateResponse) XXX_DiscardUnknown 

func (m *VolumeCreateResponse) XXX_DiscardUnknown()

func (*VolumeCreateResponse) XXX_Marshal 

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

func (*VolumeCreateResponse) XXX_Merge 

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

func (*VolumeCreateResponse) XXX_Size 

func (m *VolumeCreateResponse) XXX_Size() int

func (*VolumeCreateResponse) XXX_Unmarshal 

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

type VolumeMountRequest 

type VolumeMountRequest struct {
	VolumeName           string   `protobuf:"bytes,1,opt,name=volumeName,proto3" json:"volumeName,omitempty"`
	Mountpoint           string   `protobuf:"bytes,2,opt,name=mountpoint,proto3" json:"mountpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeMountRequest) Descriptor 

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

func (*VolumeMountRequest) GetMountpoint 

func (m *VolumeMountRequest) GetMountpoint() string

func (*VolumeMountRequest) GetVolumeName 

func (m *VolumeMountRequest) GetVolumeName() string

func (*VolumeMountRequest) ProtoMessage 

func (*VolumeMountRequest) ProtoMessage()

func (*VolumeMountRequest) Reset 

func (m *VolumeMountRequest) Reset()

func (*VolumeMountRequest) String 

func (m *VolumeMountRequest) String() string

func (*VolumeMountRequest) XXX_DiscardUnknown 

func (m *VolumeMountRequest) XXX_DiscardUnknown()

func (*VolumeMountRequest) XXX_Marshal 

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

func (*VolumeMountRequest) XXX_Merge 

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

func (*VolumeMountRequest) XXX_Size 

func (m *VolumeMountRequest) XXX_Size() int

func (*VolumeMountRequest) XXX_Unmarshal 

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

type VolumeMountResponse 

type VolumeMountResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeMountResponse) Descriptor 

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

func (*VolumeMountResponse) ProtoMessage 

func (*VolumeMountResponse) ProtoMessage()

func (*VolumeMountResponse) Reset 

func (m *VolumeMountResponse) Reset()

func (*VolumeMountResponse) String 

func (m *VolumeMountResponse) String() string

func (*VolumeMountResponse) XXX_DiscardUnknown 

func (m *VolumeMountResponse) XXX_DiscardUnknown()

func (*VolumeMountResponse) XXX_Marshal 

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

func (*VolumeMountResponse) XXX_Merge 

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

func (*VolumeMountResponse) XXX_Size 

func (m *VolumeMountResponse) XXX_Size() int

func (*VolumeMountResponse) XXX_Unmarshal 

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

type VolumeStorageAddRequest 

type VolumeStorageAddRequest struct {
	VolumeName           string   `protobuf:"bytes,1,opt,name=volumeName,proto3" json:"volumeName,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Backend              string   `protobuf:"bytes,3,opt,name=backend,proto3" json:"backend,omitempty"`
	SharingKeyName       string   `protobuf:"bytes,4,opt,name=sharingKeyName,proto3" json:"sharingKeyName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeStorageAddRequest) Descriptor 

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

func (*VolumeStorageAddRequest) GetBackend 

func (m *VolumeStorageAddRequest) GetBackend() string

func (*VolumeStorageAddRequest) GetName 

func (m *VolumeStorageAddRequest) GetName() string

func (*VolumeStorageAddRequest) GetSharingKeyName 

func (m *VolumeStorageAddRequest) GetSharingKeyName() string

func (*VolumeStorageAddRequest) GetVolumeName 

func (m *VolumeStorageAddRequest) GetVolumeName() string

func (*VolumeStorageAddRequest) ProtoMessage 

func (*VolumeStorageAddRequest) ProtoMessage()

func (*VolumeStorageAddRequest) Reset 

func (m *VolumeStorageAddRequest) Reset()

func (*VolumeStorageAddRequest) String 

func (m *VolumeStorageAddRequest) String() string

func (*VolumeStorageAddRequest) XXX_DiscardUnknown 

func (m *VolumeStorageAddRequest) XXX_DiscardUnknown()

func (*VolumeStorageAddRequest) XXX_Marshal 

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

func (*VolumeStorageAddRequest) XXX_Merge 

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

func (*VolumeStorageAddRequest) XXX_Size 

func (m *VolumeStorageAddRequest) XXX_Size() int

func (*VolumeStorageAddRequest) XXX_Unmarshal 

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

type VolumeStorageAddResponse 

type VolumeStorageAddResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeStorageAddResponse) Descriptor 

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

func (*VolumeStorageAddResponse) ProtoMessage 

func (*VolumeStorageAddResponse) ProtoMessage()

func (*VolumeStorageAddResponse) Reset 

func (m *VolumeStorageAddResponse) Reset()

func (*VolumeStorageAddResponse) String 

func (m *VolumeStorageAddResponse) String() string

func (*VolumeStorageAddResponse) XXX_DiscardUnknown 

func (m *VolumeStorageAddResponse) XXX_DiscardUnknown()

func (*VolumeStorageAddResponse) XXX_Marshal 

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

func (*VolumeStorageAddResponse) XXX_Merge 

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

func (*VolumeStorageAddResponse) XXX_Size 

func (m *VolumeStorageAddResponse) XXX_Size() int

func (*VolumeStorageAddResponse) XXX_Unmarshal 

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

type VolumeSyncRequest 

type VolumeSyncRequest struct {
	VolumeName string `protobuf:"bytes,1,opt,name=volumeName,proto3" json:"volumeName,omitempty"`
	// Must be exactly 32 bytes long.
	Pub                  []byte   `protobuf:"bytes,2,opt,name=pub,proto3" json:"pub,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeSyncRequest) Descriptor 

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

func (*VolumeSyncRequest) GetPath 

func (m *VolumeSyncRequest) GetPath() string

func (*VolumeSyncRequest) GetPub 

func (m *VolumeSyncRequest) GetPub() []byte

func (*VolumeSyncRequest) GetVolumeName 

func (m *VolumeSyncRequest) GetVolumeName() string

func (*VolumeSyncRequest) ProtoMessage 

func (*VolumeSyncRequest) ProtoMessage()

func (*VolumeSyncRequest) Reset 

func (m *VolumeSyncRequest) Reset()

func (*VolumeSyncRequest) String 

func (m *VolumeSyncRequest) String() string

func (*VolumeSyncRequest) XXX_DiscardUnknown 

func (m *VolumeSyncRequest) XXX_DiscardUnknown()

func (*VolumeSyncRequest) XXX_Marshal 

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

func (*VolumeSyncRequest) XXX_Merge 

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

func (*VolumeSyncRequest) XXX_Size 

func (m *VolumeSyncRequest) XXX_Size() int

func (*VolumeSyncRequest) XXX_Unmarshal 

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

type VolumeSyncResponse 

type VolumeSyncResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeSyncResponse) Descriptor 

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

func (*VolumeSyncResponse) ProtoMessage 

func (*VolumeSyncResponse) ProtoMessage()

func (*VolumeSyncResponse) Reset 

func (m *VolumeSyncResponse) Reset()

func (*VolumeSyncResponse) String 

func (m *VolumeSyncResponse) String() string

func (*VolumeSyncResponse) XXX_DiscardUnknown 

func (m *VolumeSyncResponse) XXX_DiscardUnknown()

func (*VolumeSyncResponse) XXX_Marshal 

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

func (*VolumeSyncResponse) XXX_Merge 

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

func (*VolumeSyncResponse) XXX_Size 

func (m *VolumeSyncResponse) XXX_Size() int

func (*VolumeSyncResponse) XXX_Unmarshal 

func (m *VolumeSyncResponse) XXX_Unmarshal(b []byte) 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.