nats

Documentation

Index

• type Client
  • func NewClient(c config.NATS, options ...IndicatorsOption) (Client, error)
  • func (ids Client) Close(ctx context.Context)
  • func (ids Client) SMA(ctx context.Context, payload client.SMAPayload) (*timeserie.TimeSerie[float64], error)
  • func (ids Client) ServiceInfo(ctx context.Context) (clientPkg.ServiceInfo, error)
• type IndicatorsOption
  • func WithIndicatorsLogger(logger extensions.Logger) IndicatorsOption

Types

type Client

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

func NewClient

func NewClient(c config.NATS, options ...IndicatorsOption) (Client, error)

func (Client) Close

func (ids Client) Close(ctx context.Context)

func (Client) SMA

func (ids Client) SMA(ctx context.Context, payload client.SMAPayload) (*timeserie.TimeSerie[float64], error)

func (Client) ServiceInfo

func (ids Client) ServiceInfo(ctx context.Context) (clientPkg.ServiceInfo, error)

type IndicatorsOption

type IndicatorsOption func(i *Client)

func WithIndicatorsLogger

func WithIndicatorsLogger(logger extensions.Logger) IndicatorsOption