service

Documentation

Overview

Package service is a generated GoMock package.

Index

• func GetBranchByProjectBaseDir(projectBaseDir string) string
• func GetUUID() string
• type CLIService
  • func NewCLIService(repo Repository, txp TxProvider, httpAddr, authKey string) *CLIService
  • func (s *CLIService) Aggregate(events model.Events)
  • func (s *CLIService) CreateEvents(ctx context.Context, events model.Events) error
  • func (s *CLIService) ReadRequestData(request string) (model.Events, error)
  • func (s *CLIService) Send(ctx context.Context, version string) error
• type MockRepository
  • func NewMockRepository(ctrl *gomock.Controller) *MockRepository
  • func (m *MockRepository) Create(ctx context.Context, events model.Events) error
  • func (m *MockRepository) Delete(ctx context.Context, events model.Events) error
  • func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
  • func (m *MockRepository) GetMarked(ctx context.Context) (model.Events, error)
  • func (m *MockRepository) MarkSent(ctx context.Context) error
  • func (m *MockRepository) WithTx(txProvider TxProvider) Repository
• type MockRepositoryMockRecorder
  • func (mr *MockRepositoryMockRecorder) Create(ctx, events interface{}) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) Delete(ctx, events interface{}) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) GetMarked(ctx interface{}) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) MarkSent(ctx interface{}) *gomock.Call
  • func (mr *MockRepositoryMockRecorder) WithTx(txProvider interface{}) *gomock.Call
• type MockTxProvider
  • func NewMockTxProvider(ctrl *gomock.Controller) *MockTxProvider
  • func (m *MockTxProvider) EXPECT() *MockTxProviderMockRecorder
  • func (m *MockTxProvider) Transaction(f func(TxProvider) error) error
• type MockTxProviderMockRecorder
  • func (mr *MockTxProviderMockRecorder) Transaction(f interface{}) *gomock.Call
• type Repository
• type TxProvider

Functions

func GetBranchByProjectBaseDir

func GetBranchByProjectBaseDir(projectBaseDir string) string

func GetUUID

func GetUUID() string

Types

type CLIService

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

func NewCLIService

func NewCLIService(repo Repository, txp TxProvider, httpAddr, authKey string) *CLIService

func (*CLIService) Aggregate

func (s *CLIService) Aggregate(events model.Events)

func (*CLIService) CreateEvents

func (s *CLIService) CreateEvents(ctx context.Context, events model.Events) error

func (*CLIService) ReadRequestData

func (s *CLIService) ReadRequestData(request string) (model.Events, error)

func (*CLIService) Send

func (s *CLIService) Send(ctx context.Context, version string) error

type MockRepository

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

MockRepository is a mock of Repository interface.

func NewMockRepository

func NewMockRepository(ctrl *gomock.Controller) *MockRepository

NewMockRepository creates a new mock instance.

func (*MockRepository) Create

func (m *MockRepository) Create(ctx context.Context, events model.Events) error

Create mocks base method.

func (*MockRepository) Delete

func (m *MockRepository) Delete(ctx context.Context, events model.Events) error

Delete mocks base method.

func (*MockRepository) EXPECT

func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRepository) GetMarked

func (m *MockRepository) GetMarked(ctx context.Context) (model.Events, error)

GetMarked mocks base method.

func (*MockRepository) MarkSent

func (m *MockRepository) MarkSent(ctx context.Context) error

MarkSent mocks base method.

func (*MockRepository) WithTx

func (m *MockRepository) WithTx(txProvider TxProvider) Repository

WithTx mocks base method.

type MockRepositoryMockRecorder

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

MockRepositoryMockRecorder is the mock recorder for MockRepository.

func (*MockRepositoryMockRecorder) Create

func (mr *MockRepositoryMockRecorder) Create(ctx, events interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockRepositoryMockRecorder) Delete

func (mr *MockRepositoryMockRecorder) Delete(ctx, events interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockRepositoryMockRecorder) GetMarked

func (mr *MockRepositoryMockRecorder) GetMarked(ctx interface{}) *gomock.Call

GetMarked indicates an expected call of GetMarked.

func (*MockRepositoryMockRecorder) MarkSent

func (mr *MockRepositoryMockRecorder) MarkSent(ctx interface{}) *gomock.Call

MarkSent indicates an expected call of MarkSent.

func (*MockRepositoryMockRecorder) WithTx

func (mr *MockRepositoryMockRecorder) WithTx(txProvider interface{}) *gomock.Call

WithTx indicates an expected call of WithTx.

type MockTxProvider

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

MockTxProvider is a mock of TxProvider interface.

func NewMockTxProvider

func NewMockTxProvider(ctrl *gomock.Controller) *MockTxProvider

NewMockTxProvider creates a new mock instance.

func (*MockTxProvider) EXPECT

func (m *MockTxProvider) EXPECT() *MockTxProviderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTxProvider) Transaction

func (m *MockTxProvider) Transaction(f func(TxProvider) error) error

Transaction mocks base method.

type MockTxProviderMockRecorder

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

MockTxProviderMockRecorder is the mock recorder for MockTxProvider.

func (*MockTxProviderMockRecorder) Transaction

func (mr *MockTxProviderMockRecorder) Transaction(f interface{}) *gomock.Call

Transaction indicates an expected call of Transaction.

type Repository

type Repository interface {
	Create(ctx context.Context, events model.Events) error
	GetMarked(ctx context.Context) (model.Events, error)
	MarkSent(ctx context.Context) error
	Delete(ctx context.Context, events model.Events) error
	WithTx(txProvider TxProvider) Repository
}

type TxProvider

type TxProvider interface {
	Transaction(f func(txProvider TxProvider) error) error
}