subscription

Documentation

Index

• func NewService(repository store.SubscriptionRepository, ...) (domain.SubscriptionService, error)
• type ClientMock
  • func (_m *ClientMock) SyncConfig(_a0 alertmanager.AMConfig, _a1 string) error
• type EnrichedReceiverMetadata
• type EnrichedReceiverMetadataList
• type ReceiverMetadata
• type Service
  • func (s Service) CreateSubscription(ctx context.Context, sub *domain.Subscription) error
  • func (s Service) DeleteSubscription(ctx context.Context, id uint64) error
  • func (s Service) GetSubscription(ctx context.Context, id uint64) (*domain.Subscription, error)
  • func (s Service) ListSubscriptions(ctx context.Context) ([]*domain.Subscription, error)
  • func (s Service) Migrate() error
  • func (s Service) UpdateSubscription(ctx context.Context, sub *domain.Subscription) error
• type StringStringMap
  • func (m *StringStringMap) Scan(value interface{}) error
  • func (a StringStringMap) Value() (driver.Value, error)
• type SubscriptionEnrichedWithReceivers
• type SubscriptionRepositoryMock
  • func (_m *SubscriptionRepositoryMock) Commit(ctx context.Context) error
  • func (_m *SubscriptionRepositoryMock) Create(_a0 context.Context, _a1 *domain.Subscription) error
  • func (_m *SubscriptionRepositoryMock) Delete(_a0 context.Context, _a1 uint64) error
  • func (_m *SubscriptionRepositoryMock) Get(_a0 context.Context, _a1 uint64) (*domain.Subscription, error)
  • func (_m *SubscriptionRepositoryMock) List(_a0 context.Context) ([]*domain.Subscription, error)
  • func (_m *SubscriptionRepositoryMock) Migrate() error
  • func (_m *SubscriptionRepositoryMock) Rollback(ctx context.Context) error
  • func (_m *SubscriptionRepositoryMock) Update(_a0 context.Context, _a1 *domain.Subscription) error
  • func (_m *SubscriptionRepositoryMock) WithTransaction(ctx context.Context) context.Context

Functions

func NewService

func NewService(repository store.SubscriptionRepository, providerRepository store.ProviderRepository, namespaceRepository store.NamespaceRepository,
	receiverRepository store.ReceiverRepository, key string) (domain.SubscriptionService, error)

NewService returns service struct

Types

type ClientMock

type ClientMock struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func (*ClientMock) SyncConfig

func (_m *ClientMock) SyncConfig(_a0 alertmanager.AMConfig, _a1 string) error

SyncConfig provides a mock function with given fields: _a0, _a1

type EnrichedReceiverMetadata

type EnrichedReceiverMetadata struct {
	Id            uint64            `json:"id"`
	Type          string            `json:"type"`
	Configuration map[string]string `json:"configuration"`
}

type EnrichedReceiverMetadataList

type EnrichedReceiverMetadataList []EnrichedReceiverMetadata

type ReceiverMetadata

type ReceiverMetadata struct {
	Id            uint64            `json:"id"`
	Configuration map[string]string `json:"configuration"`
}

type Service

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

Service handles business logic

func (Service) CreateSubscription

func (s Service) CreateSubscription(ctx context.Context, sub *domain.Subscription) error

func (Service) DeleteSubscription

func (s Service) DeleteSubscription(ctx context.Context, id uint64) error

func (Service) GetSubscription

func (s Service) GetSubscription(ctx context.Context, id uint64) (*domain.Subscription, error)

func (Service) ListSubscriptions

func (s Service) ListSubscriptions(ctx context.Context) ([]*domain.Subscription, error)

func (Service) Migrate

func (s Service) Migrate() error

func (Service) UpdateSubscription

func (s Service) UpdateSubscription(ctx context.Context, sub *domain.Subscription) error

type StringStringMap

type StringStringMap map[string]string

func (*StringStringMap) Scan

func (m *StringStringMap) Scan(value interface{}) error

func (StringStringMap) Value

func (a StringStringMap) Value() (driver.Value, error)

type SubscriptionEnrichedWithReceivers

type SubscriptionEnrichedWithReceivers struct {
	Id          uint64
	Namespace   *model.Namespace
	NamespaceId uint64
	Urn         string
	Receiver    EnrichedReceiverMetadataList
	Match       StringStringMap
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type SubscriptionRepositoryMock

type SubscriptionRepositoryMock struct {
	mock.Mock
}

SubscriptionRepositoryMock is an autogenerated mock type for the SubscriptionRepository type

func (*SubscriptionRepositoryMock) Commit

func (_m *SubscriptionRepositoryMock) Commit(ctx context.Context) error

Commit provides a mock function with given fields: ctx

func (*SubscriptionRepositoryMock) Create

func (_m *SubscriptionRepositoryMock) Create(_a0 context.Context, _a1 *domain.Subscription) error

Create provides a mock function with given fields: _a0, _a1

func (*SubscriptionRepositoryMock) Delete

func (_m *SubscriptionRepositoryMock) Delete(_a0 context.Context, _a1 uint64) error

Delete provides a mock function with given fields: _a0, _a1

func (*SubscriptionRepositoryMock) Get

func (_m *SubscriptionRepositoryMock) Get(_a0 context.Context, _a1 uint64) (*domain.Subscription, error)

Get provides a mock function with given fields: _a0, _a1

func (*SubscriptionRepositoryMock) List

func (_m *SubscriptionRepositoryMock) List(_a0 context.Context) ([]*domain.Subscription, error)

List provides a mock function with given fields: _a0

func (*SubscriptionRepositoryMock) Migrate

func (_m *SubscriptionRepositoryMock) Migrate() error

Migrate provides a mock function with given fields:

func (*SubscriptionRepositoryMock) Rollback

func (_m *SubscriptionRepositoryMock) Rollback(ctx context.Context) error

Rollback provides a mock function with given fields: ctx

func (*SubscriptionRepositoryMock) Update

func (_m *SubscriptionRepositoryMock) Update(_a0 context.Context, _a1 *domain.Subscription) error

Update provides a mock function with given fields: _a0, _a1

func (*SubscriptionRepositoryMock) WithTransaction

func (_m *SubscriptionRepositoryMock) WithTransaction(ctx context.Context) context.Context

WithTransaction provides a mock function with given fields: ctx