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 File_got_proto protoreflect.FileDescriptor
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 

func (StoreType) Type() protoreflect.EnumType

type UnimplementedGotSpaceServer 

type UnimplementedGotSpaceServer struct {
}

UnimplementedGotSpaceServer must be embedded to have forward compatible implementations.

func (UnimplementedGotSpaceServer) AddBlob 

func (UnimplementedGotSpaceServer) AddBlob(context.Context, *AddBlobReq) (*AddBlobRes, error)

func (UnimplementedGotSpaceServer) CASCell 

func (UnimplementedGotSpaceServer) CASCell(context.Context, *CASCellReq) (*CASCellRes, error)

func (UnimplementedGotSpaceServer) CreateBranch 

func (UnimplementedGotSpaceServer) CreateBranch(context.Context, *CreateBranchReq) (*BranchInfo, error)

func (UnimplementedGotSpaceServer) DeleteBlob 

func (UnimplementedGotSpaceServer) DeleteBlob(context.Context, *DeleteBlobReq) (*DeleteBlobRes, error)

func (UnimplementedGotSpaceServer) DeleteBranch 

func (UnimplementedGotSpaceServer) DeleteBranch(context.Context, *DeleteBranchReq) (*DeleteBranchRes, error)

func (UnimplementedGotSpaceServer) GetBlob 

func (UnimplementedGotSpaceServer) GetBlob(context.Context, *GetBlobReq) (*GetBlobRes, error)

func (UnimplementedGotSpaceServer) GetBranch 

func (UnimplementedGotSpaceServer) GetBranch(context.Context, *GetBranchReq) (*BranchInfo, error)

func (UnimplementedGotSpaceServer) ListBlob 

func (UnimplementedGotSpaceServer) ListBlob(context.Context, *ListBlobReq) (*ListBlobRes, error)

func (UnimplementedGotSpaceServer) ListBranch 

func (UnimplementedGotSpaceServer) ListBranch(context.Context, *ListBranchReq) (*ListBranchRes, error)

func (UnimplementedGotSpaceServer) PostBlob 

func (UnimplementedGotSpaceServer) PostBlob(context.Context, *PostBlobReq) (*PostBlobRes, error)

func (UnimplementedGotSpaceServer) ReadCell 

func (UnimplementedGotSpaceServer) ReadCell(context.Context, *ReadCellReq) (*ReadCellRes, error)

func (UnimplementedGotSpaceServer) SetBranch 

func (UnimplementedGotSpaceServer) SetBranch(context.Context, *SetBranchReq) (*BranchInfo, error)

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.

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.