repository

Documentation

Index

• Variables
• type Factory
  • func NewJsMinioFactory(storageClient storage.ClientBucket, bucket string, ...) Factory
• type JetstreamLogsRepository
  • func (r JetstreamLogsRepository) Get(ctx context.Context, id string) (chan events.LogResponse, error)
• type JsMinioFactory
  • func (b JsMinioFactory) GetRepository(s state.LogState) (LogsRepository, error)
• type LogsRepository
  • func NewJetstreamRepository(client client.StreamGetter) LogsRepository
  • func NewMinioRepository(storageClient storage.ClientBucket, bucket string) LogsRepository
• type MinioLogsRepository
  • func (r MinioLogsRepository) Get(ctx context.Context, id string) (chan events.LogResponse, error)
• type RepositoryBuilder

Variables

var ErrUnknownState = errors.New("unknown state")

Types

type Factory

type Factory interface {
	GetRepository(state state.LogState) (LogsRepository, error)
}

func NewJsMinioFactory

func NewJsMinioFactory(storageClient storage.ClientBucket, bucket string, logStream client.StreamGetter) Factory

type JetstreamLogsRepository

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

Jet

func (JetstreamLogsRepository) Get

func (r JetstreamLogsRepository) Get(ctx context.Context, id string) (chan events.LogResponse, error)

type JsMinioFactory

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

func (JsMinioFactory) GetRepository

func (b JsMinioFactory) GetRepository(s state.LogState) (LogsRepository, error)

type LogsRepository

type LogsRepository interface {
	Get(ctx context.Context, id string) (chan events.LogResponse, error)
}

LogsRepository is the repository primitive to get logs from

func NewJetstreamRepository

func NewJetstreamRepository(client client.StreamGetter) LogsRepository

func NewMinioRepository

func NewMinioRepository(storageClient storage.ClientBucket, bucket string) LogsRepository

type MinioLogsRepository

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

func (MinioLogsRepository) Get

func (r MinioLogsRepository) Get(ctx context.Context, id string) (chan events.LogResponse, error)

type RepositoryBuilder

type RepositoryBuilder interface {
	GetRepository(state state.LogState) (LogsRepository, error)
}

RepositoryBuilder is responsible for getting valid repository based on execution state It'll be ususally for OSS when we'll get from NATS buffer or from Minio (when execution completed)