applications

Documentation

Overview

Package applications Orchestration Business Use case, don't process business logic, business rule

Index

• type QueueModelUseCase
  • func NewQueueModelUseCase() *QueueModelUseCase
  • func (q *QueueModelUseCase) CreateTopic(ctx context.Context, topic string) error
  • func (q *QueueModelUseCase) DeleteTopic(ctx context.Context, topic string)
  • func (q *QueueModelUseCase) OmList(ctx context.Context) string
  • func (q *QueueModelUseCase) Produce(ctx context.Context, topic string, msg []byte) error
  • func (q *QueueModelUseCase) Subscribe(ctx context.Context, url string, topic string) error
  • func (q *QueueModelUseCase) UnSubscribe(ctx context.Context, url string, topic string)

Types

type QueueModelUseCase

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

func NewQueueModelUseCase

func NewQueueModelUseCase() *QueueModelUseCase

func (*QueueModelUseCase) CreateTopic

func (q *QueueModelUseCase) CreateTopic(ctx context.Context, topic string) error

func (*QueueModelUseCase) DeleteTopic

func (q *QueueModelUseCase) DeleteTopic(ctx context.Context, topic string)

func (*QueueModelUseCase) OmList

func (q *QueueModelUseCase) OmList(ctx context.Context) string

func (*QueueModelUseCase) Produce

func (q *QueueModelUseCase) Produce(ctx context.Context, topic string, msg []byte) error

func (*QueueModelUseCase) Subscribe

func (q *QueueModelUseCase) Subscribe(ctx context.Context, url string, topic string) error

func (*QueueModelUseCase) UnSubscribe

func (q *QueueModelUseCase) UnSubscribe(ctx context.Context, url string, topic string)