server

Documentation

Index

• Constants
• func Init()
• func ListChunk()
• func ListObject()
• func NewObject()
• func PathValidate(path string)
• func Server()
• type Chunk
  • func CreatChunk(volid, idx uint32, rep int) *Chunk
  • func OpenChunk(volid, idx uint32, rep int) *Chunk
  • func (chk *Chunk) Delete()
  • func (chk *Chunk) Read()
  • func (chk *Chunk) Ref()
  • func (chk *Chunk) UnRef()
  • func (chk *Chunk) Write()
• type Meta
  • func NewMeta() *Meta
• type Node
• type Object
  • func (obj *Object) Delete()
  • func (obj *Object) Read()
  • func (obj *Object) Write()
• type PlainStore
  • func (store *PlainStore) CreateObject(obj Object) error
  • func (store *PlainStore) DeleteObject(obj Object) error
  • func (store *PlainStore) ListObject() error
  • func (store *PlainStore) ReadObject() error
  • func (store *PlainStore) WriteObject() error
• type Store
  • func NewStore(base string) Store
• type VolumeService
  • func NewVolumeService() *VolumeService
  • func (vs *VolumeService) Upload(srv pb.VolumeService_UploadServer) error

Constants

const (
	// Address 监听地址
	Address string = ":8000"
	// Network 网络通信协议
	Network string = "tcp"
)

Functions

func Init

func Init()

func ListChunk

func ListChunk()

func ListObject

func ListObject()

func NewObject

func NewObject()

func PathValidate

func PathValidate(path string)

func Server

func Server()

Types

type Chunk

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

func CreatChunk

func CreatChunk(volid, idx uint32, rep int) *Chunk

func OpenChunk

func OpenChunk(volid, idx uint32, rep int) *Chunk

func (*Chunk) Delete

func (chk *Chunk) Delete()

func (*Chunk) Read

func (chk *Chunk) Read()

func (*Chunk) Ref

func (chk *Chunk) Ref()

func (*Chunk) UnRef

func (chk *Chunk) UnRef()

func (*Chunk) Write

func (chk *Chunk) Write()

type Meta

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

func NewMeta

func NewMeta() *Meta

type Node

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

type Object

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

func (*Object) Delete

func (obj *Object) Delete()

func (*Object) Read

func (obj *Object) Read()

func (*Object) Write

func (obj *Object) Write()

type PlainStore

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

func (*PlainStore) CreateObject

func (store *PlainStore) CreateObject(obj Object) error

func (*PlainStore) DeleteObject

func (store *PlainStore) DeleteObject(obj Object) error

func (*PlainStore) ListObject

func (store *PlainStore) ListObject() error

func (*PlainStore) ReadObject

func (store *PlainStore) ReadObject() error

func (*PlainStore) WriteObject

func (store *PlainStore) WriteObject() error

type Store

type Store interface {
	CreateObject(obj Object) error
	DeleteObject(obj Object) error
	ListObject() error
	WriteObject() error
	ReadObject() error
}

func NewStore

func NewStore(base string) Store

type VolumeService

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

func NewVolumeService

func NewVolumeService() *VolumeService

func (*VolumeService) Upload

func (vs *VolumeService) Upload(srv pb.VolumeService_UploadServer) error