wire2

Documentation

Index

• Constants
• Variables
• func NewServer(ginr groupidx.GroupIndex) *fastrpc.Server
• type Client
  • func NewClient(netw, addr string) *Client
  • func (c *Client) ArticleGroupList(group []byte, first, last int64, targ func(int64))
  • func (c *Client) ArticleGroupMove(group []byte, i int64, backward bool, id_buf []byte) (ni int64, id []byte, _ok bool)
  • func (c *Client) ArticleGroupStat(group []byte, num int64, id_buf []byte) ([]byte, bool)
  • func (c *Client) AssignArticleToGroup(group []byte, num, exp uint64, id []byte) error
  • func (c *Client) AssignArticleToGroups(groups [][]byte, nums []int64, exp uint64, id []byte) error
  • func (c *Client) GroupHeadInsert(groups [][]byte, buf []int64) ([]int64, error)
  • func (c *Client) GroupHeadRevert(groups [][]byte, nums []int64) error
  • func (c *Client) GroupRealtimeQuery(group []byte) (number int64, low int64, high int64, ok bool)
  • func (c *Client) ListArticleGroupRaw(group []byte, first, last int64, targ func(int64, []byte))
  • func (c *Client) Ping() error

Constants

const ProtocolVersion byte = 1

const SniffHeader = "GIX"

Variables

var ENoPing = errors.New("NoPing")

var ENoResult = errors.New("NoResult")

Functions

func NewServer

func NewServer(ginr groupidx.GroupIndex) *fastrpc.Server

Types

type Client

type Client struct {
	Inner client
}

func NewClient

func NewClient(netw, addr string) *Client

func (*Client) ArticleGroupList

func (c *Client) ArticleGroupList(group []byte, first, last int64, targ func(int64))

func (*Client) ArticleGroupMove

func (c *Client) ArticleGroupMove(group []byte, i int64, backward bool, id_buf []byte) (ni int64, id []byte, _ok bool)

func (*Client) ArticleGroupStat

func (c *Client) ArticleGroupStat(group []byte, num int64, id_buf []byte) ([]byte, bool)

func (*Client) AssignArticleToGroup

func (c *Client) AssignArticleToGroup(group []byte, num, exp uint64, id []byte) error

Newly introduced.

func (*Client) AssignArticleToGroups

func (c *Client) AssignArticleToGroups(groups [][]byte, nums []int64, exp uint64, id []byte) error

func (*Client) GroupHeadInsert

func (c *Client) GroupHeadInsert(groups [][]byte, buf []int64) ([]int64, error)

known from "github.com/maxymania/fastnntp-polyglot"

func (*Client) GroupHeadRevert

func (c *Client) GroupHeadRevert(groups [][]byte, nums []int64) error

func (*Client) GroupRealtimeQuery

func (c *Client) GroupRealtimeQuery(group []byte) (number int64, low int64, high int64, ok bool)

func (*Client) ListArticleGroupRaw

func (c *Client) ListArticleGroupRaw(group []byte, first, last int64, targ func(int64, []byte))

func (*Client) Ping

func (c *Client) Ping() error