factory

type BoolValue ¶

type BoolValue struct {
	Value bool
}

func NewBoolValueFromPB(msg *pb.BoolValue) *BoolValue

type BoxSpecification ¶

type BoxSpecification struct {
	Name   string
	Height int32
	Width  int32
	Depth  int32
}

func NewBoxSpecificationFromPB(msg *pb.BoxSpecification) *BoxSpecification

type Boxes ¶

type Boxes struct {
	Boxes []BoxSpecification
}

func NewBoxesFromPB(msg *pb.Boxes) *Boxes

type Empty ¶

type Empty struct {
	Page    int32
	PerPage int32
}

func NewEmptyFromPB(msg *pb.Empty) *Empty

type Endpoints ¶

type Endpoints struct {
	MakeBoxEndpoint  endpoint.Endpoint
	GetBoxesEndpoint endpoint.Endpoint
	StatusEndpoint   endpoint.Endpoint
}

func MakeEndpoints(svc Service, mwares []endpoint.Middleware) Endpoints

type GRPCServer ¶

type GRPCServer struct {
	MakeBoxGRPCHandler  kitGRPC.Handler
	GetBoxesGRPCHandler kitGRPC.Handler
	StatusGRPCHandler   kitGRPC.Handler
	// contains filtered or unexported fields
}

func NewGRPCServer(endpoints Endpoints, logger log.Logger, options ...kitGRPC.ServerOption) (*GRPCServer, error)

func (s *GRPCServer) GetBoxes(ctx context.Context, req *pb.Empty) (*pb.Boxes, error)

func (s *GRPCServer) MakeBox(ctx context.Context, req *pb.BoxSpecification) (*pb.Empty, error)

func (s *GRPCServer) Status(ctx context.Context, req *pb.Empty) (*pb.StatusMessage, error)

type Repository ¶

type Repository interface {
	MakeBox(ctx context.Context, name string, height int32, width int32, depth int32) (int32, int32, error)
	GetBoxes(ctx context.Context, page int32, perPage int32) ([]BoxSpecification, error)
	Status(ctx context.Context, page int32, perPage int32) (string, bool, error)
}

*

type MysqlConfig struct {
	Host              string `env:"DB_READ_HOST" envDefault:"local-factory"`
	Port              string `env:"DB_READ_PORT" envDefault:"3306"`
	ConnectionTimeout int    `env:"DB_READ_CONNECTION_TIMEOUT" envDefault:"5"`
	MaxConnLifetime   int    `env:"DB_READ_MAX_CONN_LIFETIME" envDefault:"0"`
	MaxIdleConns      int    `env:"DB_READ_MAX_IDLE_CONNS" envDefault:"2"`
	MaxOpenConns      int    `env:"DB_READ_MAX_OPEN_CONNS" envDefault:"0"`
	ReadTimeout       int    `env:"DB_READ_READ_TIMEOUT" envDefault:"360"`
	Username          string `env:"DB_READ_USERNAME" envDefault:"root"`
	Password          string `env:"DB_READ_PASSWORD" envDefault:"foobar"`
	DatabaseName      string `env:"DB_READ_DATABASE" envDefault:"factory"`
}

* *

*

func NewRepository(logger log.Logger, db interface{}) Repository

type Service ¶

type Service interface {
	MakeBox(ctx context.Context, name string, height int32, width int32, depth int32) (int32, int32, error)
	GetBoxes(ctx context.Context, page int32, perPage int32) ([]BoxSpecification, error)
	Status(ctx context.Context, page int32, perPage int32) (string, bool, error)
	Log() log.Logger
}

func NewHTTPClient(serverAddr string, logger log.Logger, options ...kitHTTP.ClientOption) (Service, error)

func NewService(log log.Logger, repo Repository) Service

type StatusMessage ¶

type StatusMessage struct {
	ServiceName string
	Ok          bool
}

func NewStatusMessageFromPB(msg *pb.StatusMessage) *StatusMessage

type StringValue ¶

type StringValue struct {
	Value     string
	Timestamp timestamp.Timestamp
}

func NewStringValueFromPB(msg *pb.StringValue) *StringValue