transfer

Apr 12, 2023

Changes in this version

type Transfer

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

Mar 30, 2023

Changes in this version

type Payload

+ Format map[string]interface{}

Nov 14, 2022

Changes in this version

+ type LogOption struct

+ Description string

+ Key string

+ TTL int64

type Option

+ func SetDatabase(v *mongo.Database) Option

+ func SetJetStream(v nats.JetStreamContext) Option

+ func SetNamespace(v string) Option

Oct 24, 2022

Changes in this version

type Option

+ Key string

+ TTL int64

type Payload

+ Data map[string]interface{}

+ Metadata map[string]interface{}

+ Timestamp time.Time

type Transfer

+ Db *mongo.Database

+ JetStream nats.JetStreamContext

+ KeyValue nats.KeyValue

Aug 23, 2022

Changes in this version

type Option

+ Measurement string

Aug 19, 2022

Changes in this version

type Payload

+ Fields map[string]interface{}

+ Measurement string

+ Tags map[string]string

+ Time time.Time

Apr 19, 2022

Changes in this version

+ type CLSDto struct

+ Record map[string]string

+ Time time.Time

+ TopicId string

+ type InfluxDto struct

+ Fields map[string]interface{}

+ Measurement string

+ Tags map[string]string

+ Time time.Time

+ type Option struct

+ Description string

+ Topic string

+ type Payload []byte

+ func NewPayload(data interface{}) (payload Payload, err error)

+ type Transfer struct

+ Js nats.JetStreamContext

+ Namespace string

+ Store nats.ObjectStore

+ func New(namespace string, js nats.JetStreamContext) (x *Transfer, err error)

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

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

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

+ func (x *Transfer) Set(key string, option Option) (err error)