mocks

Documentation

Index

• func Keycloak(ctx context.Context, wg *sync.WaitGroup) (url string)
• func StartTestHttpMock(ctx context.Context, wg *sync.WaitGroup, responseList []HttpMockResponse) (url string, mux *sync.Mutex, requests *[]model.HttpRequest)
• type AuthMock
  • func (this AuthMock) ExchangeUserToken(userid string) (token auth.Token, err error)
  • func (this AuthMock) GenerateUserTokenById(userid string) (token string, err error)
• type CamundaMock
  • func NewCamundaMock() *CamundaMock
  • func (this *CamundaMock) AddFileToQueue(location string) error
  • func (this *CamundaMock) AddToQueue(fetchResult []model.CamundaExternalTask)
  • func (this *CamundaMock) Fetch() (result []model.CamundaExternalTask)
  • func (this *CamundaMock) PopRequestLog() []Request
  • func (this *CamundaMock) Start(ctx context.Context, wg *sync.WaitGroup) (url string)
• type CleanupChecker
  • func (this CleanupChecker) Check(entity model.WatchedEntity) (remove bool, err error)
• type DbRecorder
  • func NewDbRecorder(config configuration.Config, libconfig libconfig.Config, db db.Database) *DbRecorder
  • func (this *DbRecorder) CheckExpectedRequests(expectedRequests map[string][]map[string]interface{}) error
  • func (this *DbRecorder) CheckExpectedRequestsFromFileLocation(fileLocation string) error
  • func (this *DbRecorder) Delete(id string, userId string) error
  • func (this *DbRecorder) Fetch(max int64) ([]model.WatchedEntity, error)
  • func (this *DbRecorder) Read(id string, userId string) (model.WatchedEntity, error)
  • func (this *DbRecorder) Set(init model.WatchedEntityInit) error
  • func (this *DbRecorder) UpdateHash(id string, userId string, hash string) error
• type HttpMockResponse
• type HttpService
  • func (this *HttpService) CheckExpectedRequests(expectedRequests []Request) error
  • func (this *HttpService) CheckExpectedRequestsFromFileLocation(fileLocation string) error
  • func (this *HttpService) GetRequestLog() []Request
  • func (this *HttpService) PopRequestLog() []Request
  • func (this *HttpService) SetResponse(method string, path string, responses []Response)
  • func (this *HttpService) SetResponses(responsesMap map[string]map[string][]Response)
  • func (this *HttpService) SetResponsesFromFile(fileLocation string) error
  • func (this *HttpService) Start(ctx context.Context, wg *sync.WaitGroup) (url string)
• type KeycloakClaims
• type RealmAccess
• type Request
• type Response
• type SmartServiceRepoMock
  • func NewSmartServiceRepoMock(libConfig lib_config.Config, config configuration.Config, ...) *SmartServiceRepoMock
  • func (this *SmartServiceRepoMock) CheckExpectedRequests(expectedRequests []Request) error
  • func (this *SmartServiceRepoMock) CheckExpectedRequestsFromFileLocation(fileLocation string) error
  • func (this *SmartServiceRepoMock) GetRequestLog() []Request
  • func (this *SmartServiceRepoMock) PopRequestLog() []Request
  • func (this *SmartServiceRepoMock) Start(ctx context.Context, wg *sync.WaitGroup) (url string)

Functions

func Keycloak

func Keycloak(ctx context.Context, wg *sync.WaitGroup) (url string)

func StartTestHttpMock

func StartTestHttpMock(ctx context.Context, wg *sync.WaitGroup, responseList []HttpMockResponse) (url string, mux *sync.Mutex, requests *[]model.HttpRequest)

Types

type AuthMock

type AuthMock struct{}

func (AuthMock) ExchangeUserToken

func (this AuthMock) ExchangeUserToken(userid string) (token auth.Token, err error)

func (AuthMock) GenerateUserTokenById

func (this AuthMock) GenerateUserTokenById(userid string) (token string, err error)

type CamundaMock

type CamundaMock struct {
	Queue chan []model.CamundaExternalTask
	// contains filtered or unexported fields
}

func NewCamundaMock

func NewCamundaMock() *CamundaMock

func (*CamundaMock) AddFileToQueue

func (this *CamundaMock) AddFileToQueue(location string) error

func (*CamundaMock) AddToQueue

func (this *CamundaMock) AddToQueue(fetchResult []model.CamundaExternalTask)

func (*CamundaMock) Fetch

func (this *CamundaMock) Fetch() (result []model.CamundaExternalTask)

func (*CamundaMock) PopRequestLog

func (this *CamundaMock) PopRequestLog() []Request

func (*CamundaMock) Start

func (this *CamundaMock) Start(ctx context.Context, wg *sync.WaitGroup) (url string)

type CleanupChecker

type CleanupChecker struct{}

func (CleanupChecker) Check

func (this CleanupChecker) Check(entity model.WatchedEntity) (remove bool, err error)

type DbRecorder

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

func NewDbRecorder

func NewDbRecorder(config configuration.Config, libconfig libconfig.Config, db db.Database) *DbRecorder

func (*DbRecorder) CheckExpectedRequests

func (this *DbRecorder) CheckExpectedRequests(expectedRequests map[string][]map[string]interface{}) error

func (*DbRecorder) CheckExpectedRequestsFromFileLocation

func (this *DbRecorder) CheckExpectedRequestsFromFileLocation(fileLocation string) error

func (*DbRecorder) Delete

func (this *DbRecorder) Delete(id string, userId string) error

func (*DbRecorder) Fetch

func (this *DbRecorder) Fetch(max int64) ([]model.WatchedEntity, error)

func (*DbRecorder) Read

func (this *DbRecorder) Read(id string, userId string) (model.WatchedEntity, error)

func (*DbRecorder) Set

func (this *DbRecorder) Set(init model.WatchedEntityInit) error

func (*DbRecorder) UpdateHash

func (this *DbRecorder) UpdateHash(id string, userId string, hash string) error

type HttpMockResponse

type HttpMockResponse struct {
	Payload []byte
	Code    int
}

type HttpService

type HttpService struct {
	ResponseIndex map[string]map[string]int        //method -> path = request-count
	Response      map[string]map[string][]Response //method -> path -> request-count = response
	// contains filtered or unexported fields
}

func (*HttpService) CheckExpectedRequests

func (this *HttpService) CheckExpectedRequests(expectedRequests []Request) error

func (*HttpService) CheckExpectedRequestsFromFileLocation

func (this *HttpService) CheckExpectedRequestsFromFileLocation(fileLocation string) error

func (*HttpService) GetRequestLog

func (this *HttpService) GetRequestLog() []Request

func (*HttpService) PopRequestLog

func (this *HttpService) PopRequestLog() []Request

func (*HttpService) SetResponse

func (this *HttpService) SetResponse(method string, path string, responses []Response)

func (*HttpService) SetResponses

func (this *HttpService) SetResponses(responsesMap map[string]map[string][]Response)

func (*HttpService) SetResponsesFromFile

func (this *HttpService) SetResponsesFromFile(fileLocation string) error

func (*HttpService) Start

func (this *HttpService) Start(ctx context.Context, wg *sync.WaitGroup) (url string)

type KeycloakClaims

type KeycloakClaims struct {
	RealmAccess RealmAccess `json:"realm_access"`
	jwt.StandardClaims
}

type RealmAccess

type RealmAccess struct {
	Roles []string `json:"roles"`
}

type Request

type Request struct {
	Method   string `json:"method"`
	Endpoint string `json:"endpoint"`
	Message  string `json:"message"`
}

type Response

type Response struct {
	StatusCode int    `json:"status_code"`
	Message    string `json:"message"`
}

type SmartServiceRepoMock

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

func NewSmartServiceRepoMock

func NewSmartServiceRepoMock(libConfig lib_config.Config, config configuration.Config, moduleListResponse []byte) *SmartServiceRepoMock

func (*SmartServiceRepoMock) CheckExpectedRequests

func (this *SmartServiceRepoMock) CheckExpectedRequests(expectedRequests []Request) error

func (*SmartServiceRepoMock) CheckExpectedRequestsFromFileLocation

func (this *SmartServiceRepoMock) CheckExpectedRequestsFromFileLocation(fileLocation string) error

func (*SmartServiceRepoMock) GetRequestLog

func (this *SmartServiceRepoMock) GetRequestLog() []Request

func (*SmartServiceRepoMock) PopRequestLog

func (this *SmartServiceRepoMock) PopRequestLog() []Request

func (*SmartServiceRepoMock) Start

func (this *SmartServiceRepoMock) Start(ctx context.Context, wg *sync.WaitGroup) (url string)