client

Aug 24, 2021

Changes in this version

type RPC

+ func (r *RPC) DDL() *addl.DDL

+ func (r *RPC) ResolveDDL(ctx context.Context) error

type RPCReply

+ Action string

+ func ParseReply(reply protocol.Reply) (*RPCReply, error)

type Stats

+ func (s *Stats) UniqueRequestID() string

Apr 22, 2021

Changes in this version

type RequestOption

+ func ServiceRequest() RequestOption

Feb 3, 2021

Changes in this version

type RPCReply

+ Sender string

+ Time time.Time

Jan 13, 2021

Changes in this version

type ChoriaFramework

+ PQLQueryCertNames func(query string) ([]string, error)

type Option

+ func DiscoveryMethod(dm string) Option

type RPCReply

+ func (r *RPCReply) MatchExpr(q string) (bool, error)

type RequestOption

+ func ReplyExprFilter(f string) RequestOption

type RequestOptions

+ ReplyExprFilter string

Jul 18, 2020

Changes in this version

type Stats

+ func (s *Stats) OverrideDiscoveryTime(start time.Time, end time.Time)

+ func (s *Stats) Started() time.Time

Apr 19, 2020

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 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)

+ type Connector interface

+ Publish func(msg *choria.Message) error

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

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

+ type DiscoveryStartFunc func()

+ 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 ChoriaFramework, 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 DiscoveryEndCB(h DiscoveryEndFunc) RequestOption

+ func DiscoveryStartCB(h DiscoveryStartFunc) RequestOption

+ func DiscoveryTimeout(t time.Duration) RequestOption

+ func Filter(f *protocol.Filter) RequestOption

+ func InBatches(size int, sleep int) RequestOption

+ func LimitMethod(m string) RequestOption

+ func LimitSeed(s int64) RequestOption

+ func LimitSize(s string) 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 Workers(w int) RequestOption

+ type RequestOptions struct

+ BatchSize int

+ BatchSleep time.Duration

+ Collective string

+ ConnectionName string

+ DiscoveryEndCB DiscoveryEndFunc

+ DiscoveryStartCB DiscoveryStartFunc

+ DiscoveryTimeout time.Duration

+ Filter *protocol.Filter

+ Handler Handler

+ LimitMethod string

+ LimitSeed int64

+ LimitSize string

+ ProcessReplies bool

+ ProtocolVersion string

+ Replies chan *choria.ConnectorMessage

+ ReplyTo string

+ RequestID string

+ RequestType string

+ Targets []string

+ Timeout time.Duration

+ Workers int

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

+ func (o *RequestOptions) ConfigureMessage(msg *choria.Message) (err 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) StartPublish()

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

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