reader

Documentation

Index

• Constants
• Variables
• type Callback
• type CallbackList
• type Service
  • func NewService(clientHttp *http.Client, uriBase string) Service
  • func NewServiceLogging(svc Service, log *slog.Logger) Service
  • func NewServiceMock() Service

Constants

const FmtJson = "json"

const KeyHubMode = "hub.mode"

const KeyHubTopic = "hub.topic"

const QueryParamFollower = "follower"

Variables

var ErrConflict = errors.New("conflict")

var ErrInternal = errors.New("internal failure")

var ErrNotFound = errors.New("not found")

Types

type Callback

type Callback struct {
	Url    string `json:"url"`
	Format string `json:"fmt"`
}

type CallbackList

type CallbackList struct {
	Count int64 `json:"count"`
}

type Service

type Service interface {
	CreateCallback(ctx context.Context, subId, url string) (err error)
	GetCallback(ctx context.Context, subId, url string) (cb Callback, err error)
	DeleteCallback(ctx context.Context, subId, url string) (err error)
	CountByInterest(ctx context.Context, interestId string) (count int64, err error)
	Read(ctx context.Context, interestId string, limit int) (last []*pb.CloudEvent, err error)
}

func NewService

func NewService(clientHttp *http.Client, uriBase string) Service

func NewServiceLogging

func NewServiceLogging(svc Service, log *slog.Logger) Service

func NewServiceMock

func NewServiceMock() Service