krps

Documentation

Index

• type SendReqRecordSt
• type SendReqSt
• type St
  • func New(lg logger.Lite, httpc httpc.HttpC) *St
  • func (s *St) SendJson(topic, key string, value any) error
  • func (s *St) SendManyJson(topic, key string, value []any) error

Types

type SendReqRecordSt

type SendReqRecordSt struct {
	Key   string `json:"key"`
	Value any    `json:"value"`
}

type SendReqSt

type SendReqSt struct {
	Records []SendReqRecordSt `json:"records"`
}

type St

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

func New

func New(lg logger.Lite, httpc httpc.HttpC) *St

func (*St) SendJson

func (s *St) SendJson(topic, key string, value any) error

func (*St) SendManyJson

func (s *St) SendManyJson(topic, key string, value []any) error