client

Documentation

Index

• func Parse(p string, cp *CliPayload) error
• func Run(args []string)
• func RunWithOptions(options *Options) error
• type C
• type CliPayload
  • func (c *CliPayload) Bind(k string, value interface{}, msg *client.Message) error
  • func (c *CliPayload) Iterator(pair common.Pair) error
  • func (c *CliPayload) Pair(key string, value interface{}) error
  • func (c *CliPayload) SetBatch(msg *client.Message)
• type Options
  • func (o *Options) Hosts() []*client.Host
  • func (o *Options) Init()
  • func (o *Options) Payload() (*CliPayload, error)
  • func (o *Options) Validate() error

Functions

func Parse

func Parse(p string, cp *CliPayload) error

func Run

func Run(args []string)

func RunWithOptions

func RunWithOptions(options *Options) error

Types

type C

type C uint8

const (
	None C = iota
	Single
	Batch
)

type CliPayload

type CliPayload struct {
	Data  map[string]interface{}
	Batch int
}

func (*CliPayload) Bind

func (c *CliPayload) Bind(k string, value interface{}, msg *client.Message) error

func (*CliPayload) Iterator

func (c *CliPayload) Iterator(pair common.Pair) error

func (*CliPayload) Pair

func (c *CliPayload) Pair(key string, value interface{}) error

Not implementating this side of interface, not used -- the interface itself may not be necessary

func (*CliPayload) SetBatch

func (c *CliPayload) SetBatch(msg *client.Message)

type Options

type Options struct {
	Host       string `short:"h" long:"host" description:"endpoint host"`
	Port       int    `short:"p" long:"port" description:"endpoint port"`
	Debug      bool   `long:"debug"`
	Model      string `short:"m" long:"model" description:"model"`
	Storable   string `short:"s" long:"storable"`
	PayloadStr string `short:"a" long:"payload"`
	Format     string `short:"f" long:"format" choice:"mly" choice:"json"`
}

func (*Options) Hosts

func (o *Options) Hosts() []*client.Host

func (*Options) Init

func (o *Options) Init()

func (*Options) Payload

func (o *Options) Payload() (*CliPayload, error)

func (*Options) Validate

func (o *Options) Validate() error