timesync

Documentation

Index

• Constants
• func DecodeTimesyncRequests(r io.Reader) <-chan TimesyncRequest
• func EncodeTimesyncReplies(w io.Writer) chan<- TimesyncReply
• func EncodeTimesyncReply(w io.Writer, reply TimesyncReply) error
• func HandleTimesyncProtocol(ctx context.Context, conn net.Conn, impl ProtocolImpl) error
• func ListenSingleConnection(ctx context.Context, sockpath string) (net.Conn, error)
• func ListenUnix(ctx context.Context, sockpath string) (<-chan net.Conn, error)
• func OnCancel(ctx context.Context, cb func())
• func OnInterrupt(ctx context.Context, cb func())
• func Simple(sockpath string, app ProtocolImpl) error
• type ProtocolImpl
• type TimesyncReply
• type TimesyncRequest
  • func DecodeTimesyncRequest(r io.Reader) (TimesyncRequest, error)

Constants

const (
	TimesyncLeaderMagic   = 0x71DE7EAD
	TimesyncFollowerMagic = 0x71DEF011
)

Functions

func DecodeTimesyncRequests

func DecodeTimesyncRequests(r io.Reader) <-chan TimesyncRequest

func EncodeTimesyncReplies

func EncodeTimesyncReplies(w io.Writer) chan<- TimesyncReply

func EncodeTimesyncReply

func EncodeTimesyncReply(w io.Writer, reply TimesyncReply) error

func HandleTimesyncProtocol

func HandleTimesyncProtocol(ctx context.Context, conn net.Conn, impl ProtocolImpl) error

func ListenSingleConnection

func ListenSingleConnection(ctx context.Context, sockpath string) (net.Conn, error)

func ListenUnix

func ListenUnix(ctx context.Context, sockpath string) (<-chan net.Conn, error)

func OnCancel

func OnCancel(ctx context.Context, cb func())

func OnInterrupt

func OnInterrupt(ctx context.Context, cb func())

func Simple

func Simple(sockpath string, app ProtocolImpl) error

Types

type ProtocolImpl

type ProtocolImpl interface {
	Sync(pendingReadBytes int, now int64, writeData []byte) (expireAt int64, readData []byte)
}

type TimesyncReply

type TimesyncReply struct {
	SeqNum   uint32
	ExpireAt int64
	Data     []byte
}

type TimesyncRequest

type TimesyncRequest struct {
	SeqNum           uint32
	PendingReadBytes uint32
	Now              int64
	Data             []byte
}

func DecodeTimesyncRequest

func DecodeTimesyncRequest(r io.Reader) (TimesyncRequest, error)