job_distributor

Documentation

Index

• Constants
• type Component
  • func New(networks []string, opts ...Option) *Component
  • func (j *Component) RestartContainer() error
  • func (j *Component) StartContainer() error
• type Option
  • func WithCSAKeyEncryptionKey(key string) Option
  • func WithContainerName(name string) Option
  • func WithContainerPort(port string) Option
  • func WithDBURL(db string) Option
  • func WithImage(image string) Option
  • func WithTestInstance(t *testing.T) Option
  • func WithVersion(version string) Option
  • func WithWSRPCContainerPort(port string) Option

Constants

const (
	JDContainerName            string = "job-distributor"
	DEAFULTJDContainerPort     string = "42242"
	DEFAULTCSAKeyEncryptionKey string = "!PASsword000!"
	DEAFULTWSRPCContainerPort  string = "8080"
)

Types

type Component

type Component struct {
	test_env.EnvComponent
	Grpc          string
	Wsrpc         string
	InternalGRPC  string
	InternalWSRPC string
	// contains filtered or unexported fields
}

func New

func New(networks []string, opts ...Option) *Component

func (*Component) RestartContainer

func (j *Component) RestartContainer() error

func (*Component) StartContainer

func (j *Component) StartContainer() error

type Option

type Option = func(j *Component)

func WithCSAKeyEncryptionKey

func WithCSAKeyEncryptionKey(key string) Option

func WithContainerName

func WithContainerName(name string) Option

func WithContainerPort

func WithContainerPort(port string) Option

func WithDBURL

func WithDBURL(db string) Option

func WithImage

func WithImage(image string) Option

func WithTestInstance

func WithTestInstance(t *testing.T) Option

func WithVersion

func WithVersion(version string) Option

func WithWSRPCContainerPort

func WithWSRPCContainerPort(port string) Option