dataUpdate

Documentation

Index

• type DataUpdate
  • func NewDataUpdate(c conf.EventConf) (DataUpdate, error)
• type NatsClient
  • func (n *NatsClient) UpdateWithTopic(ctx context.Context, topic string, info any) error

Types

type DataUpdate

type DataUpdate interface {
	UpdateWithTopic(ctx context.Context, topic string, info any) error
}

func NewDataUpdate

func NewDataUpdate(c conf.EventConf) (DataUpdate, error)

type NatsClient

type NatsClient struct {
	// contains filtered or unexported fields
}

func (*NatsClient) UpdateWithTopic

func (n *NatsClient) UpdateWithTopic(ctx context.Context, topic string, info any) error