transfer

README

Weplanx Transfer

A Golang version of client for managing configuration, data transfer, and scheduling distribution collectors.

License

BSD-3-Clause License

Documentation

Index

• type LogOption
• type Option
  • func SetJetStream(v nats.JetStreamContext) Option
  • func SetNamespace(v string) Option
• type Payload
• type Transfer
  • func New(options ...Option) (x *Transfer, err error)
  • func (x *Transfer) Get(key string) (result map[string]interface{}, err error)
  • func (x *Transfer) Publish(ctx context.Context, key string, payload Payload) (err error)
  • func (x *Transfer) Remove(key string) (err error)
  • func (x *Transfer) Set(ctx context.Context, option LogOption) (err error)
  • func (x *Transfer) Update(ctx context.Context, option LogOption) (err error)

Types

type LogOption

type LogOption struct {
	Key         string `msgpack:"key"`
	Description string `msgpack:"description"`
}

type Option

type Option func(x *Transfer)

func SetJetStream

func SetJetStream(v nats.JetStreamContext) Option

func SetNamespace

func SetNamespace(v string) Option

type Payload

type Payload struct {
	Timestamp time.Time              `msgpack:"timestamp"`
	Data      map[string]interface{} `msgpack:"data"`
	Format    map[string]interface{} `msgpack:"format"`
}

type Transfer

type Transfer struct {
	Namespace string
	Js        nats.JetStreamContext
	KeyValue  nats.KeyValue
}

func New

func New(options ...Option) (x *Transfer, err error)

func (*Transfer) Get

func (x *Transfer) Get(key string) (result map[string]interface{}, err error)

func (*Transfer) Publish

func (x *Transfer) Publish(ctx context.Context, key string, payload Payload) (err error)

func (*Transfer) Remove

func (x *Transfer) Remove(key string) (err error)

func (*Transfer) Set

func (x *Transfer) Set(ctx context.Context, option LogOption) (err error)

func (*Transfer) Update

func (x *Transfer) Update(ctx context.Context, option LogOption) (err error)