client

package

Go to main page

Versions in this module

v0

v0.10.0

Jan 12, 2020

v0.9.0

Dec 7, 2019

v0.8.0

Sep 19, 2019

v0.7.1

Sep 8, 2019

v0.7.0

Sep 7, 2019

v0.6.1

Sep 6, 2019

v0.6.0

Sep 6, 2019

Changes in this version

+ type DiscoveryEndFunc func(discovered int, limited int) error

+ type DiscoveryStartFunc func()

type RequestOption

+ func DiscoveryEndCB(h DiscoveryEndFunc) RequestOption

+ func DiscoveryStartCB(h DiscoveryStartFunc) RequestOption

+ func LimitMethod(m string) RequestOption

+ func LimitSeed(s int64) RequestOption

+ func LimitSize(s string) RequestOption

type RequestOptions

+ DiscoveryEndCB DiscoveryEndFunc

+ DiscoveryStartCB DiscoveryStartFunc

+ LimitMethod string

+ LimitSeed int64

+ LimitSize string

v0.5.0

Jul 24, 2019

Changes in this version

+ type ChoriaFramework interface

+ Certname func() string

+ Configuration func() *config.Config

+ Logger func(string) *logrus.Entry

+ MiddlewareServers func() (servers srvcache.Servers, err error)

+ NewConnector func(ctx context.Context, servers func() (srvcache.Servers, error), name string, ...) (conn choria.Connector, err error)

+ NewMessage func(payload string, agent string, collective string, msgType string, ...) (msg *choria.Message, err error)

+ NewReplyFromTransportJSON func(payload []byte, skipvalidate bool) (msg protocol.Reply, err error)

+ NewRequestID func() (string, error)

+ NewTransportFromJSON func(data string) (message protocol.TransportMessage, err error)

v0.4.1

Jun 21, 2019

Changes in this version

+ func InGroups(set []string, size int, f func([]string) error) error

+ func InterruptableSleep(ctx context.Context, d time.Duration) error

+ type ChoriaClient interface

+ Request func(ctx context.Context, msg *choria.Message, handler cclient.Handler) (err error)

+ type Connector interface

+ Publish func(msg *choria.Message) error

+ QueueSubscribe func(ctx context.Context, name string, subject string, group string, ...) error

+ type Handler func(protocol.Reply, *RPCReply)

+ type NodeList struct

+ func NewNodeList() *NodeList

+ func (n *NodeList) AddHosts(hosts ...string)

+ func (n *NodeList) Clear()

+ func (n *NodeList) Count() int

+ func (n *NodeList) DeleteIfKnown(host string) bool

+ func (n *NodeList) Have(host string) bool

+ func (n *NodeList) HaveAny(hosts ...string) bool

+ func (n *NodeList) Hosts() []string

+ type Option func(r *RPC)

+ func DDL(d *addl.DDL) Option

+ type RPC struct

+ func New(fw *choria.Framework, agent string, opts ...Option) (rpc *RPC, err error)

+ func (r *RPC) Do(ctx context.Context, action string, payload interface{}, opts ...RequestOption) (RequestResult, error)

+ func (r *RPC) Reset()

+ type RPCReply struct

+ Data json.RawMessage

+ Statuscode mcorpc.StatusCode

+ Statusmsg string

+ func ParseReplyData(source []byte) (*RPCReply, error)

+ type RPCRequest struct

+ Action string

+ Agent string

+ Data json.RawMessage

+ type RequestOption func(*RequestOptions)

+ func BroadcastRequest() RequestOption

+ func Collective(c string) RequestOption

+ func ConnectionName(n string) RequestOption

+ func DirectRequest() RequestOption

+ func DiscoveryTimeout(t time.Duration) RequestOption

+ func Filter(f *protocol.Filter) RequestOption

+ func InBatches(size int, sleep int) RequestOption

+ func Protocol(v string) RequestOption

+ func Replies(r chan *choria.ConnectorMessage) RequestOption

+ func ReplyHandler(f Handler) RequestOption

+ func ReplyTo(r string) RequestOption

+ func Targets(t []string) RequestOption

+ func Timeout(t time.Duration) RequestOption

+ func WithProgress() RequestOption

+ func Workers(w int) RequestOption

+ type RequestOptions struct

+ BatchSize int

+ BatchSleep time.Duration

+ Collective string

+ ConnectionName string

+ DiscoveryTimeout time.Duration

+ Filter *protocol.Filter

+ Handler Handler

+ ProcessReplies bool

+ Progress bool

+ ProtocolVersion string

+ Replies chan *choria.ConnectorMessage

+ ReplyTo string

+ RequestID string

+ RequestType string

+ Targets []string

+ Timeout time.Duration

+ Workers int

+ func NewRequestOptions(fw *choria.Framework, ddl *agent.DDL) (*RequestOptions, error)

+ func (o *RequestOptions) ConfigureMessage(msg *choria.Message) error

+ func (o *RequestOptions) Stats() *Stats

+ type RequestResult interface

+ Stats func() *Stats

+ type Stats struct

+ RequestID string

+ func NewStats() *Stats

+ func (s *Stats) Action() string

+ func (s *Stats) Agent() string

+ func (s *Stats) All() bool

+ func (s *Stats) DiscoveredCount() int

+ func (s *Stats) DiscoveredNodes() *[]string

+ func (s *Stats) DiscoveryDuration() (time.Duration, error)

+ func (s *Stats) End()

+ func (s *Stats) EndDiscover()

+ func (s *Stats) EndPublish()

+ func (s *Stats) FailCount() int

+ func (s *Stats) FailedRequestInc()

+ func (s *Stats) Merge(other *Stats) error

+ func (s *Stats) NoResponseFrom() []string

+ func (s *Stats) OKCount() int

+ func (s *Stats) PassedRequestInc()

+ func (s *Stats) PublishDuration() (time.Duration, error)

+ func (s *Stats) RecordReceived(sender string)

+ func (s *Stats) RequestDuration() (time.Duration, error)

+ func (s *Stats) ResponsesCount() int

+ func (s *Stats) SetAction(a string)

+ func (s *Stats) SetAgent(a string)

+ func (s *Stats) SetDiscoveredNodes(nodes []string)

+ func (s *Stats) Start()

+ func (s *Stats) StartDiscover()

+ func (s *Stats) StartProgress(ctx context.Context)

+ func (s *Stats) StartPublish()

+ func (s *Stats) UnexpectedResponseFrom() []string

+ func (s *Stats) WaitingFor(nodes []string) bool

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