autumn

Documentation

Index

• func NewAutumnHandler(ctx context.Context, autumnLib *AutumnLib) (builder.DataProcHandler, error)
• type AutumnHandler
  • func (a *AutumnHandler) DeleteData(params *types.DeleteData) (err error)
  • func (a *AutumnHandler) Get(params *types.GetData) (data []byte, size uint64, err error)
  • func (a *AutumnHandler) Put(params *types.PutData, data []byte) (err error)
• type AutumnLib
  • func NewAutumnLib(etcdAddr []string) *AutumnLib
  • func (lib *AutumnLib) Close()
  • func (lib *AutumnLib) Connect(ctx context.Context) error
  • func (lib *AutumnLib) Delete(ctx context.Context, key []byte) error
  • func (lib *AutumnLib) Get(ctx context.Context, key []byte) ([]byte, uint64, error)
  • func (lib *AutumnLib) Put(ctx context.Context, key, value []byte) error

Functions

func NewAutumnHandler

func NewAutumnHandler(ctx context.Context, autumnLib *AutumnLib) (builder.DataProcHandler, error)

Types

type AutumnHandler

type AutumnHandler struct {
	Ctx       context.Context
	AutumnLib *AutumnLib
}

func (*AutumnHandler) DeleteData

func (a *AutumnHandler) DeleteData(params *types.DeleteData) (err error)

func (*AutumnHandler) Get

func (a *AutumnHandler) Get(params *types.GetData) (data []byte, size uint64, err error)

func (*AutumnHandler) Put

func (a *AutumnHandler) Put(params *types.PutData, data []byte) (err error)

type AutumnLib

type AutumnLib struct {
	utils.SafeMutex //protect regions and psDetails
	// contains filtered or unexported fields
}

func NewAutumnLib

func NewAutumnLib(etcdAddr []string) *AutumnLib

func (*AutumnLib) Close

func (lib *AutumnLib) Close()

func (*AutumnLib) Connect

func (lib *AutumnLib) Connect(ctx context.Context) error

func (*AutumnLib) Delete

func (lib *AutumnLib) Delete(ctx context.Context, key []byte) error

func (*AutumnLib) Get

func (lib *AutumnLib) Get(ctx context.Context, key []byte) ([]byte, uint64, error)

func (*AutumnLib) Put

func (lib *AutumnLib) Put(ctx context.Context, key, value []byte) error