message

Documentation

Overview

Package message is handles concurrent message objects

Index

• func NewService(repo Repository, client client.Client, entity core.EntityService, ...) core.MessageService
• type Handler
  • func NewHandler(service core.MessageService) Handler
• type Repository
  • func NewRepository(db *gorm.DB, mc *memcache.Client, schema core.SchemaService) Repository

Functions

func NewService

func NewService(
	repo Repository,
	client client.Client,
	entity core.EntityService,
	domain core.DomainService,
	timeline core.TimelineService,
	key core.KeyService,
	policy core.PolicyService,
	config core.Config,
) core.MessageService

NewService creates a new message service

Types

type Handler

type Handler interface {
	Get(c echo.Context) error
}

Handler is the interface for handling HTTP requests

func NewHandler

func NewHandler(service core.MessageService) Handler

NewHandler creates a new handler

type Repository

type Repository interface {
	Create(ctx context.Context, message core.Message) (core.Message, error)
	Get(ctx context.Context, key string) (core.Message, error)
	GetWithOwnAssociations(ctx context.Context, key string, ccid string) (core.Message, error)
	Delete(ctx context.Context, key string) error
	Clean(ctx context.Context, ccid string) error
	Count(ctx context.Context) (int64, error)
}

Repository is the interface for message repository

func NewRepository

func NewRepository(db *gorm.DB, mc *memcache.Client, schema core.SchemaService) Repository

NewRepository creates a new message repository