transfer

Documentation

Index

• type Option
  • func SetJetStream(v nats.JetStreamContext) Option
  • func SetNamespace(v string) Option
• type Payload
• type StreamOption
• 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 StreamOption) (err error)
  • func (x *Transfer) Update(ctx context.Context, option StreamOption) (err error)

Types

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"`
	XData     map[string]interface{} `msgpack:"xdata"`
}

type StreamOption

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

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 StreamOption) (err error)

func (*Transfer) Update

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