remote

Documentation

Index

• type GhaClient
  • func (g *GhaClient) AdmCreateGroup(group []byte) int
  • func (g *GhaClient) GetDown(group []byte) (int64, error)
  • func (g *GhaClient) GroupHeadInsert(groups [][]byte, buf []int64) ([]int64, error)
  • func (g *GhaClient) GroupHeadRevert(groups [][]byte, nums []int64) error
  • func (g *GhaClient) MoveDown(group []byte) (int64, error)
  • func (g *GhaClient) UpdateDown(group []byte, oldHigh, low, high, count int64) (bool, error)
• type GhaService
  • func (g *GhaService) Handler(ctx *fasthttp.RequestCtx)
• type HttpClient

Types

type GhaClient

type GhaClient struct {
	Client HttpClient
}

func (*GhaClient) AdmCreateGroup

func (g *GhaClient) AdmCreateGroup(group []byte) int

func (*GhaClient) GetDown

func (g *GhaClient) GetDown(group []byte) (int64, error)

func (*GhaClient) GroupHeadInsert

func (g *GhaClient) GroupHeadInsert(groups [][]byte, buf []int64) ([]int64, error)

func (*GhaClient) GroupHeadRevert

func (g *GhaClient) GroupHeadRevert(groups [][]byte, nums []int64) error

func (*GhaClient) MoveDown

func (g *GhaClient) MoveDown(group []byte) (int64, error)

func (*GhaClient) UpdateDown

func (g *GhaClient) UpdateDown(group []byte, oldHigh, low, high, count int64) (bool, error)

type GhaService

type GhaService struct {
	Actor *groups.GroupHeadActor
}

func (*GhaService) Handler

func (g *GhaService) Handler(ctx *fasthttp.RequestCtx)

type HttpClient

type HttpClient interface {
	DoDeadline(req *fasthttp.Request, resp *fasthttp.Response, deadline time.Time) error
}