gotgrpc

package
v0.0.4 Latest Latest
Warning

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

Go to latest
Published: Jul 21, 2022 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MaxBlobSize = gotfs.DefaultMaxBlobSize
	MaxCellSize = 1 << 16
)

Variables

View Source
var (
	StoreType_name = map[int32]string{
		0: "RAW",
		1: "FS",
		2: "VC",
	}
	StoreType_value = map[string]int32{
		"RAW": 0,
		"FS":  1,
		"VC":  2,
	}
)

Enum value maps for StoreType.

View Source
var (
	Mode_name = map[int32]string{
		0: "FROZEN",
		1: "EXPAND",
		2: "SHRINK",
	}
	Mode_value = map[string]int32{
		"FROZEN": 0,
		"EXPAND": 1,
		"SHRINK": 2,
	}
)

Enum value maps for Mode.

View Source
var GotSpace_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "got.GotSpace",
	HandlerType: (*GotSpaceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBranch",
			Handler:    _GotSpace_CreateBranch_Handler,
		},
		{
			MethodName: "GetBranch",
			Handler:    _GotSpace_GetBranch_Handler,
		},
		{
			MethodName: "DeleteBranch",
			Handler:    _GotSpace_DeleteBranch_Handler,
		},
		{
			MethodName: "ListBranch",
			Handler:    _GotSpace_ListBranch_Handler,
		},
		{
			MethodName: "SetBranch",
			Handler:    _GotSpace_SetBranch_Handler,
		},
		{
			MethodName: "PostBlob",
			Handler:    _GotSpace_PostBlob_Handler,
		},
		{
			MethodName: "GetBlob",
			Handler:    _GotSpace_GetBlob_Handler,
		},
		{
			MethodName: "DeleteBlob",
			Handler:    _GotSpace_DeleteBlob_Handler,
		},
		{
			MethodName: "AddBlob",
			Handler:    _GotSpace_AddBlob_Handler,
		},
		{
			MethodName: "ListBlob",
			Handler:    _GotSpace_ListBlob_Handler,
		},
		{
			MethodName: "ReadCell",
			Handler:    _GotSpace_ReadCell_Handler,
		},
		{
			MethodName: "CASCell",
			Handler:    _GotSpace_CASCell_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "got.proto",
}

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

Functions

func Hash

func Hash(x []byte) cadata.ID

func RegisterGotSpaceServer

func RegisterGotSpaceServer(s grpc.ServiceRegistrar, srv GotSpaceServer)

func WithHeaders

func WithHeaders(headers map[string]string) grpc.DialOption

WithHeaders adds headers to all requests made by the dialer

Types

type AddBlobReq

type AddBlobReq struct {
	Key       string    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	StoreType StoreType `protobuf:"varint,2,opt,name=store_type,json=storeType,proto3,enum=got.StoreType" json:"store_type,omitempty"`
	Id        []byte    `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddBlobReq) Descriptor deprecated

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

Deprecated: Use AddBlobReq.ProtoReflect.Descriptor instead.

func (*AddBlobReq) GetId

func (x *AddBlobReq) GetId() []byte

func (*AddBlobReq) GetKey

func (x *AddBlobReq) GetKey() string

func (*AddBlobReq) GetStoreType

func (x *AddBlobReq) GetStoreType() StoreType

func (*AddBlobReq) ProtoMessage

func (*AddBlobReq) ProtoMessage()

func (*AddBlobReq) ProtoReflect

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

func (*AddBlobReq) Reset

func (x *AddBlobReq) Reset()

func (*AddBlobReq) String

func (x *AddBlobReq) String() string

type AddBlobRes

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

func (*AddBlobRes) Descriptor deprecated

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

Deprecated: Use AddBlobRes.ProtoReflect.Descriptor instead.

func (*AddBlobRes) ProtoMessage

func (*AddBlobRes) ProtoMessage()

func (*AddBlobRes) ProtoReflect

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

func (*AddBlobRes) Reset

func (x *AddBlobRes) Reset()

func (*AddBlobRes) String

func (x *AddBlobRes) String() string

type Annotation

type Annotation struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Annotation) Descriptor deprecated

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

Deprecated: Use Annotation.ProtoReflect.Descriptor instead.

func (*Annotation) GetKey

func (x *Annotation) GetKey() string

func (*Annotation) GetValue

func (x *Annotation) GetValue() string

func (*Annotation) ProtoMessage

func (*Annotation) ProtoMessage()

func (*Annotation) ProtoReflect

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

func (*Annotation) Reset

func (x *Annotation) Reset()

func (*Annotation) String

func (x *Annotation) String() string

type BranchInfo

type BranchInfo struct {
	Salt        []byte        `protobuf:"bytes,1,opt,name=salt,proto3" json:"salt,omitempty"`
	CreatedAt   []byte        `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Annotations []*Annotation `protobuf:"bytes,3,rep,name=annotations,proto3" json:"annotations,omitempty"`
	Mode        Mode          `protobuf:"varint,4,opt,name=mode,proto3,enum=got.Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*BranchInfo) Descriptor deprecated

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

Deprecated: Use BranchInfo.ProtoReflect.Descriptor instead.

func (*BranchInfo) GetAnnotations

func (x *BranchInfo) GetAnnotations() []*Annotation

func (*BranchInfo) GetCreatedAt

func (x *BranchInfo) GetCreatedAt() []byte

func (*BranchInfo) GetMode added in v0.0.4

func (x *BranchInfo) GetMode() Mode

func (*BranchInfo) GetSalt

func (x *BranchInfo) GetSalt() []byte

func (*BranchInfo) ProtoMessage

func (*BranchInfo) ProtoMessage()

func (*BranchInfo) ProtoReflect

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

func (*BranchInfo) Reset

func (x *BranchInfo) Reset()

func (*BranchInfo) String

func (x *BranchInfo) String() string

type CASCellReq

type CASCellReq struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	PrevHash []byte `protobuf:"bytes,2,opt,name=prev_hash,json=prevHash,proto3" json:"prev_hash,omitempty"`
	Next     []byte `protobuf:"bytes,3,opt,name=next,proto3" json:"next,omitempty"`
	// contains filtered or unexported fields
}

func (*CASCellReq) Descriptor deprecated

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

Deprecated: Use CASCellReq.ProtoReflect.Descriptor instead.

func (*CASCellReq) GetKey

func (x *CASCellReq) GetKey() string

func (*CASCellReq) GetNext

func (x *CASCellReq) GetNext() []byte

func (*CASCellReq) GetPrevHash

func (x *CASCellReq) GetPrevHash() []byte

func (*CASCellReq) ProtoMessage

func (*CASCellReq) ProtoMessage()

func (*CASCellReq) ProtoReflect

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

func (*CASCellReq) Reset

func (x *CASCellReq) Reset()

func (*CASCellReq) String

func (x *CASCellReq) String() string

type CASCellRes

type CASCellRes struct {
	Current []byte `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	Swapped bool   `protobuf:"varint,2,opt,name=swapped,proto3" json:"swapped,omitempty"`
	// contains filtered or unexported fields
}

func (*CASCellRes) Descriptor deprecated

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

Deprecated: Use CASCellRes.ProtoReflect.Descriptor instead.

func (*CASCellRes) GetCurrent

func (x *CASCellRes) GetCurrent() []byte

func (*CASCellRes) GetSwapped

func (x *CASCellRes) GetSwapped() bool

func (*CASCellRes) ProtoMessage

func (*CASCellRes) ProtoMessage()

func (*CASCellRes) ProtoReflect

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

func (*CASCellRes) Reset

func (x *CASCellRes) Reset()

func (*CASCellRes) String

func (x *CASCellRes) String() string

type Cell

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

func (*Cell) CAS

func (c *Cell) CAS(ctx context.Context, actual, prev, next []byte) (bool, int, error)

func (*Cell) MaxSize

func (c *Cell) MaxSize() int

func (*Cell) Read

func (c *Cell) Read(ctx context.Context, buf []byte) (int, error)

type CreateBranchReq

type CreateBranchReq struct {
	Key  string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Salt []byte `protobuf:"bytes,2,opt,name=salt,proto3" json:"salt,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBranchReq) Descriptor deprecated

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

Deprecated: Use CreateBranchReq.ProtoReflect.Descriptor instead.

func (*CreateBranchReq) GetKey

func (x *CreateBranchReq) GetKey() string

func (*CreateBranchReq) GetSalt

func (x *CreateBranchReq) GetSalt() []byte

func (*CreateBranchReq) ProtoMessage

func (*CreateBranchReq) ProtoMessage()

func (*CreateBranchReq) ProtoReflect

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

func (*CreateBranchReq) Reset

func (x *CreateBranchReq) Reset()

func (*CreateBranchReq) String

func (x *CreateBranchReq) String() string

type DeleteBlobReq

type DeleteBlobReq struct {
	Key       string    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	StoreType StoreType `protobuf:"varint,2,opt,name=store_type,json=storeType,proto3,enum=got.StoreType" json:"store_type,omitempty"`
	Id        []byte    `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBlobReq) Descriptor deprecated

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

Deprecated: Use DeleteBlobReq.ProtoReflect.Descriptor instead.

func (*DeleteBlobReq) GetId

func (x *DeleteBlobReq) GetId() []byte

func (*DeleteBlobReq) GetKey

func (x *DeleteBlobReq) GetKey() string

func (*DeleteBlobReq) GetStoreType

func (x *DeleteBlobReq) GetStoreType() StoreType

func (*DeleteBlobReq) ProtoMessage

func (*DeleteBlobReq) ProtoMessage()

func (*DeleteBlobReq) ProtoReflect

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

func (*DeleteBlobReq) Reset

func (x *DeleteBlobReq) Reset()

func (*DeleteBlobReq) String

func (x *DeleteBlobReq) String() string

type DeleteBlobRes

type DeleteBlobRes struct {
	Affected bool `protobuf:"varint,1,opt,name=affected,proto3" json:"affected,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBlobRes) Descriptor deprecated

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

Deprecated: Use DeleteBlobRes.ProtoReflect.Descriptor instead.

func (*DeleteBlobRes) GetAffected

func (x *DeleteBlobRes) GetAffected() bool

func (*DeleteBlobRes) ProtoMessage

func (*DeleteBlobRes) ProtoMessage()

func (*DeleteBlobRes) ProtoReflect

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

func (*DeleteBlobRes) Reset

func (x *DeleteBlobRes) Reset()

func (*DeleteBlobRes) String

func (x *DeleteBlobRes) String() string

type DeleteBranchReq

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

func (*DeleteBranchReq) Descriptor deprecated

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

Deprecated: Use DeleteBranchReq.ProtoReflect.Descriptor instead.

func (*DeleteBranchReq) GetKey

func (x *DeleteBranchReq) GetKey() string

func (*DeleteBranchReq) ProtoMessage

func (*DeleteBranchReq) ProtoMessage()

func (*DeleteBranchReq) ProtoReflect

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

func (*DeleteBranchReq) Reset

func (x *DeleteBranchReq) Reset()

func (*DeleteBranchReq) String

func (x *DeleteBranchReq) String() string

type DeleteBranchRes

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

func (*DeleteBranchRes) Descriptor deprecated

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

Deprecated: Use DeleteBranchRes.ProtoReflect.Descriptor instead.

func (*DeleteBranchRes) ProtoMessage

func (*DeleteBranchRes) ProtoMessage()

func (*DeleteBranchRes) ProtoReflect

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

func (*DeleteBranchRes) Reset

func (x *DeleteBranchRes) Reset()

func (*DeleteBranchRes) String

func (x *DeleteBranchRes) String() string

type GetBlobReq

type GetBlobReq struct {
	Key       string    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	StoreType StoreType `protobuf:"varint,2,opt,name=store_type,json=storeType,proto3,enum=got.StoreType" json:"store_type,omitempty"`
	Id        []byte    `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlobReq) Descriptor deprecated

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

Deprecated: Use GetBlobReq.ProtoReflect.Descriptor instead.

func (*GetBlobReq) GetId

func (x *GetBlobReq) GetId() []byte

func (*GetBlobReq) GetKey

func (x *GetBlobReq) GetKey() string

func (*GetBlobReq) GetStoreType

func (x *GetBlobReq) GetStoreType() StoreType

func (*GetBlobReq) ProtoMessage

func (*GetBlobReq) ProtoMessage()

func (*GetBlobReq) ProtoReflect

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

func (*GetBlobReq) Reset

func (x *GetBlobReq) Reset()

func (*GetBlobReq) String

func (x *GetBlobReq) String() string

type GetBlobRes

type GetBlobRes struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlobRes) Descriptor deprecated

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

Deprecated: Use GetBlobRes.ProtoReflect.Descriptor instead.

func (*GetBlobRes) GetData

func (x *GetBlobRes) GetData() []byte

func (*GetBlobRes) ProtoMessage

func (*GetBlobRes) ProtoMessage()

func (*GetBlobRes) ProtoReflect

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

func (*GetBlobRes) Reset

func (x *GetBlobRes) Reset()

func (*GetBlobRes) String

func (x *GetBlobRes) String() string

type GetBranchReq

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

func (*GetBranchReq) Descriptor deprecated

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

Deprecated: Use GetBranchReq.ProtoReflect.Descriptor instead.

func (*GetBranchReq) GetKey

func (x *GetBranchReq) GetKey() string

func (*GetBranchReq) ProtoMessage

func (*GetBranchReq) ProtoMessage()

func (*GetBranchReq) ProtoReflect

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

func (*GetBranchReq) Reset

func (x *GetBranchReq) Reset()

func (*GetBranchReq) String

func (x *GetBranchReq) String() string

type GotSpaceClient

type GotSpaceClient interface {
	CreateBranch(ctx context.Context, in *CreateBranchReq, opts ...grpc.CallOption) (*BranchInfo, error)
	GetBranch(ctx context.Context, in *GetBranchReq, opts ...grpc.CallOption) (*BranchInfo, error)
	DeleteBranch(ctx context.Context, in *DeleteBranchReq, opts ...grpc.CallOption) (*DeleteBranchRes, error)
	ListBranch(ctx context.Context, in *ListBranchReq, opts ...grpc.CallOption) (*ListBranchRes, error)
	SetBranch(ctx context.Context, in *SetBranchReq, opts ...grpc.CallOption) (*BranchInfo, error)
	PostBlob(ctx context.Context, in *PostBlobReq, opts ...grpc.CallOption) (*PostBlobRes, error)
	GetBlob(ctx context.Context, in *GetBlobReq, opts ...grpc.CallOption) (*GetBlobRes, error)
	DeleteBlob(ctx context.Context, in *DeleteBlobReq, opts ...grpc.CallOption) (*DeleteBlobRes, error)
	AddBlob(ctx context.Context, in *AddBlobReq, opts ...grpc.CallOption) (*AddBlobRes, error)
	ListBlob(ctx context.Context, in *ListBlobReq, opts ...grpc.CallOption) (*ListBlobRes, error)
	ReadCell(ctx context.Context, in *ReadCellReq, opts ...grpc.CallOption) (*ReadCellRes, error)
	CASCell(ctx context.Context, in *CASCellReq, opts ...grpc.CallOption) (*CASCellRes, error)
}

GotSpaceClient is the client API for GotSpace 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 NewGotSpaceClient

func NewGotSpaceClient(cc grpc.ClientConnInterface) GotSpaceClient

type GotSpaceServer

type GotSpaceServer interface {
	CreateBranch(context.Context, *CreateBranchReq) (*BranchInfo, error)
	GetBranch(context.Context, *GetBranchReq) (*BranchInfo, error)
	DeleteBranch(context.Context, *DeleteBranchReq) (*DeleteBranchRes, error)
	ListBranch(context.Context, *ListBranchReq) (*ListBranchRes, error)
	SetBranch(context.Context, *SetBranchReq) (*BranchInfo, error)
	PostBlob(context.Context, *PostBlobReq) (*PostBlobRes, error)
	GetBlob(context.Context, *GetBlobReq) (*GetBlobRes, error)
	DeleteBlob(context.Context, *DeleteBlobReq) (*DeleteBlobRes, error)
	AddBlob(context.Context, *AddBlobReq) (*AddBlobRes, error)
	ListBlob(context.Context, *ListBlobReq) (*ListBlobRes, error)
	ReadCell(context.Context, *ReadCellReq) (*ReadCellRes, error)
	CASCell(context.Context, *CASCellReq) (*CASCellRes, error)
	// contains filtered or unexported methods
}

GotSpaceServer is the server API for GotSpace service. All implementations must embed UnimplementedGotSpaceServer for forward compatibility

type ListBlobReq

type ListBlobReq struct {
	Key       string    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	StoreType StoreType `protobuf:"varint,2,opt,name=store_type,json=storeType,proto3,enum=got.StoreType" json:"store_type,omitempty"`
	Begin     []byte    `protobuf:"bytes,3,opt,name=begin,proto3" json:"begin,omitempty"`
	End       []byte    `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"`
	Limit     uint32    `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBlobReq) Descriptor deprecated

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

Deprecated: Use ListBlobReq.ProtoReflect.Descriptor instead.

func (*ListBlobReq) GetBegin

func (x *ListBlobReq) GetBegin() []byte

func (*ListBlobReq) GetEnd

func (x *ListBlobReq) GetEnd() []byte

func (*ListBlobReq) GetKey

func (x *ListBlobReq) GetKey() string

func (*ListBlobReq) GetLimit

func (x *ListBlobReq) GetLimit() uint32

func (*ListBlobReq) GetStoreType

func (x *ListBlobReq) GetStoreType() StoreType

func (*ListBlobReq) ProtoMessage

func (*ListBlobReq) ProtoMessage()

func (*ListBlobReq) ProtoReflect

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

func (*ListBlobReq) Reset

func (x *ListBlobReq) Reset()

func (*ListBlobReq) String

func (x *ListBlobReq) String() string

type ListBlobRes

type ListBlobRes struct {
	Ids [][]byte `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBlobRes) Descriptor deprecated

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

Deprecated: Use ListBlobRes.ProtoReflect.Descriptor instead.

func (*ListBlobRes) GetIds

func (x *ListBlobRes) GetIds() [][]byte

func (*ListBlobRes) ProtoMessage

func (*ListBlobRes) ProtoMessage()

func (*ListBlobRes) ProtoReflect

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

func (*ListBlobRes) Reset

func (x *ListBlobRes) Reset()

func (*ListBlobRes) String

func (x *ListBlobRes) String() string

type ListBranchReq

type ListBranchReq struct {
	Begin string `protobuf:"bytes,1,opt,name=begin,proto3" json:"begin,omitempty"`
	End   string `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBranchReq) Descriptor deprecated

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

Deprecated: Use ListBranchReq.ProtoReflect.Descriptor instead.

func (*ListBranchReq) GetBegin

func (x *ListBranchReq) GetBegin() string

func (*ListBranchReq) GetEnd

func (x *ListBranchReq) GetEnd() string

func (*ListBranchReq) ProtoMessage

func (*ListBranchReq) ProtoMessage()

func (*ListBranchReq) ProtoReflect

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

func (*ListBranchReq) Reset

func (x *ListBranchReq) Reset()

func (*ListBranchReq) String

func (x *ListBranchReq) String() string

type ListBranchRes

type ListBranchRes struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBranchRes) Descriptor deprecated

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

Deprecated: Use ListBranchRes.ProtoReflect.Descriptor instead.

func (*ListBranchRes) GetKeys

func (x *ListBranchRes) GetKeys() []string

func (*ListBranchRes) ProtoMessage

func (*ListBranchRes) ProtoMessage()

func (*ListBranchRes) ProtoReflect

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

func (*ListBranchRes) Reset

func (x *ListBranchRes) Reset()

func (*ListBranchRes) String

func (x *ListBranchRes) String() string

type Mode

type Mode int32
const (
	Mode_FROZEN Mode = 0
	Mode_EXPAND Mode = 1
	Mode_SHRINK Mode = 2
)

func (Mode) Descriptor

func (Mode) Descriptor() protoreflect.EnumDescriptor

func (Mode) Enum

func (x Mode) Enum() *Mode

func (Mode) EnumDescriptor deprecated

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

Deprecated: Use Mode.Descriptor instead.

func (Mode) Number

func (x Mode) Number() protoreflect.EnumNumber

func (Mode) String

func (x Mode) String() string

func (Mode) Type

func (Mode) Type() protoreflect.EnumType

type PostBlobReq

type PostBlobReq struct {
	Key       string    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	StoreType StoreType `protobuf:"varint,2,opt,name=store_type,json=storeType,proto3,enum=got.StoreType" json:"store_type,omitempty"`
	Data      []byte    `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PostBlobReq) Descriptor deprecated

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

Deprecated: Use PostBlobReq.ProtoReflect.Descriptor instead.

func (*PostBlobReq) GetData

func (x *PostBlobReq) GetData() []byte

func (*PostBlobReq) GetKey

func (x *PostBlobReq) GetKey() string

func (*PostBlobReq) GetStoreType

func (x *PostBlobReq) GetStoreType() StoreType

func (*PostBlobReq) ProtoMessage

func (*PostBlobReq) ProtoMessage()

func (*PostBlobReq) ProtoReflect

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

func (*PostBlobReq) Reset

func (x *PostBlobReq) Reset()

func (*PostBlobReq) String

func (x *PostBlobReq) String() string

type PostBlobRes

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

func (*PostBlobRes) Descriptor deprecated

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

Deprecated: Use PostBlobRes.ProtoReflect.Descriptor instead.

func (*PostBlobRes) GetId

func (x *PostBlobRes) GetId() []byte

func (*PostBlobRes) ProtoMessage

func (*PostBlobRes) ProtoMessage()

func (*PostBlobRes) ProtoReflect

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

func (*PostBlobRes) Reset

func (x *PostBlobRes) Reset()

func (*PostBlobRes) String

func (x *PostBlobRes) String() string

type ReadCellReq

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

func (*ReadCellReq) Descriptor deprecated

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

Deprecated: Use ReadCellReq.ProtoReflect.Descriptor instead.

func (*ReadCellReq) GetKey

func (x *ReadCellReq) GetKey() string

func (*ReadCellReq) ProtoMessage

func (*ReadCellReq) ProtoMessage()

func (*ReadCellReq) ProtoReflect

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

func (*ReadCellReq) Reset

func (x *ReadCellReq) Reset()

func (*ReadCellReq) String

func (x *ReadCellReq) String() string

type ReadCellRes

type ReadCellRes struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadCellRes) Descriptor deprecated

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

Deprecated: Use ReadCellRes.ProtoReflect.Descriptor instead.

func (*ReadCellRes) GetData

func (x *ReadCellRes) GetData() []byte

func (*ReadCellRes) ProtoMessage

func (*ReadCellRes) ProtoMessage()

func (*ReadCellRes) ProtoReflect

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

func (*ReadCellRes) Reset

func (x *ReadCellRes) Reset()

func (*ReadCellRes) String

func (x *ReadCellRes) String() string

type SetBranchReq

type SetBranchReq struct {
	Key         string        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Salt        []byte        `protobuf:"bytes,2,opt,name=salt,proto3" json:"salt,omitempty"`
	Mode        Mode          `protobuf:"varint,3,opt,name=mode,proto3,enum=got.Mode" json:"mode,omitempty"`
	Annotations []*Annotation `protobuf:"bytes,4,rep,name=annotations,proto3" json:"annotations,omitempty"`
	// contains filtered or unexported fields
}

func (*SetBranchReq) Descriptor deprecated

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

Deprecated: Use SetBranchReq.ProtoReflect.Descriptor instead.

func (*SetBranchReq) GetAnnotations

func (x *SetBranchReq) GetAnnotations() []*Annotation

func (*SetBranchReq) GetKey

func (x *SetBranchReq) GetKey() string

func (*SetBranchReq) GetMode

func (x *SetBranchReq) GetMode() Mode

func (*SetBranchReq) GetSalt

func (x *SetBranchReq) GetSalt() []byte

func (*SetBranchReq) ProtoMessage

func (*SetBranchReq) ProtoMessage()

func (*SetBranchReq) ProtoReflect

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

func (*SetBranchReq) Reset

func (x *SetBranchReq) Reset()

func (*SetBranchReq) String

func (x *SetBranchReq) String() string

type Space

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

func NewSpace

func NewSpace(c GotSpaceClient) Space

func (Space) Create

func (s Space) Create(ctx context.Context, key string, md branches.Metadata) (*branches.Branch, error)

func (Space) Delete

func (s Space) Delete(ctx context.Context, key string) error

func (Space) Get

func (s Space) Get(ctx context.Context, key string) (*branches.Branch, error)

func (Space) List

func (s Space) List(ctx context.Context, span branches.Span, limit int) ([]string, error)

func (Space) Set

func (s Space) Set(ctx context.Context, key string, md branches.Metadata) error

type Store

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

func (Store) Add

func (s Store) Add(ctx context.Context, id cadata.ID) error

func (Store) Delete

func (s Store) Delete(ctx context.Context, id cadata.ID) error

func (Store) Get

func (s Store) Get(ctx context.Context, id cadata.ID, buf []byte) (int, error)

func (Store) Hash

func (s Store) Hash(x []byte) cadata.ID

func (Store) List

func (s Store) List(ctx context.Context, span cadata.Span, ids []cadata.ID) (int, error)

func (Store) MaxSize

func (s Store) MaxSize() int

func (Store) Post

func (s Store) Post(ctx context.Context, data []byte) (cadata.ID, error)

type StoreType

type StoreType int32
const (
	StoreType_RAW StoreType = 0
	StoreType_FS  StoreType = 1
	StoreType_VC  StoreType = 2
)

func (StoreType) Descriptor

func (StoreType) Descriptor() protoreflect.EnumDescriptor

func (StoreType) Enum

func (x StoreType) Enum() *StoreType

func (StoreType) EnumDescriptor deprecated

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

Deprecated: Use StoreType.Descriptor instead.

func (StoreType) Number

func (x StoreType) Number() protoreflect.EnumNumber

func (StoreType) String

func (x StoreType) String() string

func (StoreType) Type

type UnimplementedGotSpaceServer

type UnimplementedGotSpaceServer struct {
}

UnimplementedGotSpaceServer must be embedded to have forward compatible implementations.

func (UnimplementedGotSpaceServer) AddBlob

func (UnimplementedGotSpaceServer) CASCell

func (UnimplementedGotSpaceServer) CreateBranch

func (UnimplementedGotSpaceServer) DeleteBlob

func (UnimplementedGotSpaceServer) DeleteBranch

func (UnimplementedGotSpaceServer) GetBlob

func (UnimplementedGotSpaceServer) GetBranch

func (UnimplementedGotSpaceServer) ListBlob

func (UnimplementedGotSpaceServer) ListBranch

func (UnimplementedGotSpaceServer) PostBlob

func (UnimplementedGotSpaceServer) ReadCell

func (UnimplementedGotSpaceServer) SetBranch

type UnsafeGotSpaceServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL