wire1

package
v0.0.0-...-060dca9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 27, 2018 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ENoPing = errors.New("NoPing")
View Source
var ENoResult = errors.New("NoResult")

Functions

This section is empty.

Types

type Client

type Client struct {
	Inner ssh.Conn
}

func NewClient

func NewClient(c net.Conn, addr, user, pwd string, o ...Option) (*Client, error)

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

type Option

type Option interface {
	// contains filtered or unexported methods
}

func FastCiphersOption

func FastCiphersOption() Option

func FastKexOption

func FastKexOption() Option

type RawHandler

type RawHandler struct {
	WireHandler
	Config ssh.ServerConfig
}

func (*RawHandler) Handle

func (r *RawHandler) Handle(conn net.Conn) error

func (*RawHandler) SetCompatibleCiphers

func (r *RawHandler) SetCompatibleCiphers()

func (*RawHandler) SetCompatibleMac

func (r *RawHandler) SetCompatibleMac()

func (*RawHandler) SetSafeCiphers

func (r *RawHandler) SetSafeCiphers()

type WireHandler

type WireHandler struct {
	Inner groupidx.GroupIndex
	// contains filtered or unexported fields
}

func (*WireHandler) HandleConnection

func (wh *WireHandler) HandleConnection(conn *ssh.ServerConn, chs <-chan ssh.NewChannel, reqs <-chan *ssh.Request)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL