modules

Documentation

Index

• type ConsulRegistry
  • func (cr *ConsulRegistry) Register() error
• type ConsulRegistryBuilder
  • func NewConsulRegistryBuilder(environment *models.Environment) *ConsulRegistryBuilder
  • func (crb *ConsulRegistryBuilder) Build() (*ConsulRegistry, error)
  • func (crb *ConsulRegistryBuilder) WithHealthCheckingPort(port int) *ConsulRegistryBuilder
  • func (crb *ConsulRegistryBuilder) WithID(id string) *ConsulRegistryBuilder
  • func (crb *ConsulRegistryBuilder) WithName(name string) *ConsulRegistryBuilder
• type Minio
  • func (m *Minio) Create(key string, data interface{}) error
  • func (m *Minio) Delete(key string) error
  • func (m *Minio) List() ([]interface{}, error)
  • func (m *Minio) Read(key string) (interface{}, error)
  • func (m *Minio) Update(key string, data interface{}) error
• type MinioBuilder
  • func NewMinioBuilder(environment *models.Environment) *MinioBuilder
  • func (mb *MinioBuilder) Build() (*Minio, error)
  • func (mb *MinioBuilder) WithAccessKey(accessKey string) *MinioBuilder
  • func (mb *MinioBuilder) WithBucket(name string) *MinioBuilder
  • func (mb *MinioBuilder) WithEndpoint(endpoint string) *MinioBuilder
  • func (mb *MinioBuilder) WithLocation(name string) *MinioBuilder
  • func (mb *MinioBuilder) WithSecretKey(secretKey string) *MinioBuilder
• type Nats
  • func (n *Nats) Close()
  • func (n *Nats) Connect() error
  • func (n *Nats) Endpoint() string
  • func (n *Nats) Publish(topic string, message interface{}) error
  • func (n *Nats) Run() error
  • func (n *Nats) Subscribe(topic string, handler nats.MsgHandler) error
  • func (n *Nats) Unsubscribe(topic string) error
• type NatsBuilder
  • func NewNatsBuilder(environment *models.Environment) *NatsBuilder
  • func (nb *NatsBuilder) Build() (*Nats, error)
  • func (nb *NatsBuilder) WithEndpoint(endpoint string) *NatsBuilder
  • func (nb *NatsBuilder) WithUserCredentialsPath(path string) *NatsBuilder
• type Rest
  • func (r *Rest) DeleteHandler(endpoint string, handler interface{})
  • func (r *Rest) GetHandler(endpoint string, handler interface{})
  • func (r *Rest) Middleware(middleware interface{})
  • func (r *Rest) PostHandler(endpoint string, handler interface{})
  • func (r *Rest) PutHandler(endpoint string, handler interface{})
  • func (r *Rest) Run() error
  • func (r *Rest) StaticFilesFolder(uri, folder string)
  • func (r *Rest) Stop() error
• type RestBuilder
  • func NewRestBuilder(environment *models.Environment) *RestBuilder
  • func (rb *RestBuilder) Build() (*Rest, error)
  • func (rb *RestBuilder) WithDeleteHandler(path string, handler func(ctx *gin.Context)) *RestBuilder
  • func (rb *RestBuilder) WithGetHandler(path string, handler func(ctx *gin.Context)) *RestBuilder
  • func (rb *RestBuilder) WithMiddleware(middleware func(ctx *gin.Context)) *RestBuilder
  • func (rb *RestBuilder) WithPort(port int) *RestBuilder
  • func (rb *RestBuilder) WithPostHandler(path string, handler func(ctx *gin.Context)) *RestBuilder
  • func (rb *RestBuilder) WithPutHandler(path string, handler func(ctx *gin.Context)) *RestBuilder
  • func (rb *RestBuilder) WithReadTimeout(duration time.Duration) *RestBuilder
  • func (rb *RestBuilder) WithStaticFilesFolder(uri, folder string) *RestBuilder
  • func (rb *RestBuilder) WithTLS(pem, key string) *RestBuilder
  • func (rb *RestBuilder) WithWriteTimeout(duration time.Duration) *RestBuilder

Types

type ConsulRegistry

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

func (*ConsulRegistry) Register

func (cr *ConsulRegistry) Register() error

type ConsulRegistryBuilder

type ConsulRegistryBuilder struct {
	*models.Environment
	*ConsulRegistry
	models.Exception
}

func NewConsulRegistryBuilder

func NewConsulRegistryBuilder(environment *models.Environment) *ConsulRegistryBuilder

func (*ConsulRegistryBuilder) Build

func (crb *ConsulRegistryBuilder) Build() (*ConsulRegistry, error)

func (*ConsulRegistryBuilder) WithHealthCheckingPort

func (crb *ConsulRegistryBuilder) WithHealthCheckingPort(port int) *ConsulRegistryBuilder

func (*ConsulRegistryBuilder) WithID

func (crb *ConsulRegistryBuilder) WithID(id string) *ConsulRegistryBuilder

func (*ConsulRegistryBuilder) WithName

func (crb *ConsulRegistryBuilder) WithName(name string) *ConsulRegistryBuilder

type Minio

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

func (*Minio) Create

func (m *Minio) Create(key string, data interface{}) error

func (*Minio) Delete

func (m *Minio) Delete(key string) error

func (*Minio) List

func (m *Minio) List() ([]interface{}, error)

func (*Minio) Read

func (m *Minio) Read(key string) (interface{}, error)

func (*Minio) Update

func (m *Minio) Update(key string, data interface{}) error

type MinioBuilder

type MinioBuilder struct {
	*models.Environment
	*Minio
}

func NewMinioBuilder

func NewMinioBuilder(environment *models.Environment) *MinioBuilder

func (*MinioBuilder) Build

func (mb *MinioBuilder) Build() (*Minio, error)

func (*MinioBuilder) WithAccessKey

func (mb *MinioBuilder) WithAccessKey(accessKey string) *MinioBuilder

func (*MinioBuilder) WithBucket

func (mb *MinioBuilder) WithBucket(name string) *MinioBuilder

func (*MinioBuilder) WithEndpoint

func (mb *MinioBuilder) WithEndpoint(endpoint string) *MinioBuilder

func (*MinioBuilder) WithLocation

func (mb *MinioBuilder) WithLocation(name string) *MinioBuilder

func (*MinioBuilder) WithSecretKey

func (mb *MinioBuilder) WithSecretKey(secretKey string) *MinioBuilder

type Nats

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

func (*Nats) Close

func (n *Nats) Close()

func (*Nats) Connect

func (n *Nats) Connect() error

func (*Nats) Endpoint

func (n *Nats) Endpoint() string

func (*Nats) Publish

func (n *Nats) Publish(topic string, message interface{}) error

func (*Nats) Run

func (n *Nats) Run() error

func (*Nats) Subscribe

func (n *Nats) Subscribe(topic string, handler nats.MsgHandler) error

func (*Nats) Unsubscribe

func (n *Nats) Unsubscribe(topic string) error

type NatsBuilder

type NatsBuilder struct {
	*models.Environment
	*Nats
	models.Exception
}

func NewNatsBuilder

func NewNatsBuilder(environment *models.Environment) *NatsBuilder

func (*NatsBuilder) Build

func (nb *NatsBuilder) Build() (*Nats, error)

func (*NatsBuilder) WithEndpoint

func (nb *NatsBuilder) WithEndpoint(endpoint string) *NatsBuilder

func (*NatsBuilder) WithUserCredentialsPath

func (nb *NatsBuilder) WithUserCredentialsPath(path string) *NatsBuilder

type Rest

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

Rest Server

func (*Rest) DeleteHandler

func (r *Rest) DeleteHandler(endpoint string, handler interface{})

func (*Rest) GetHandler

func (r *Rest) GetHandler(endpoint string, handler interface{})

func (*Rest) Middleware

func (r *Rest) Middleware(middleware interface{})

func (*Rest) PostHandler

func (r *Rest) PostHandler(endpoint string, handler interface{})

func (*Rest) PutHandler

func (r *Rest) PutHandler(endpoint string, handler interface{})

func (*Rest) Run

func (r *Rest) Run() error

func (*Rest) StaticFilesFolder

func (r *Rest) StaticFilesFolder(uri, folder string)

func (*Rest) Stop

func (r *Rest) Stop() error

type RestBuilder

type RestBuilder struct {
	*models.Environment
	*Rest
	models.Exception
}

Rest builder

func NewRestBuilder

func NewRestBuilder(environment *models.Environment) *RestBuilder

func (*RestBuilder) Build

func (rb *RestBuilder) Build() (*Rest, error)

func (*RestBuilder) WithDeleteHandler

func (rb *RestBuilder) WithDeleteHandler(path string, handler func(ctx *gin.Context)) *RestBuilder

func (*RestBuilder) WithGetHandler

func (rb *RestBuilder) WithGetHandler(path string, handler func(ctx *gin.Context)) *RestBuilder

func (*RestBuilder) WithMiddleware

func (rb *RestBuilder) WithMiddleware(middleware func(ctx *gin.Context)) *RestBuilder

func (*RestBuilder) WithPort

func (rb *RestBuilder) WithPort(port int) *RestBuilder

func (*RestBuilder) WithPostHandler

func (rb *RestBuilder) WithPostHandler(path string, handler func(ctx *gin.Context)) *RestBuilder

func (*RestBuilder) WithPutHandler

func (rb *RestBuilder) WithPutHandler(path string, handler func(ctx *gin.Context)) *RestBuilder

func (*RestBuilder) WithReadTimeout

func (rb *RestBuilder) WithReadTimeout(duration time.Duration) *RestBuilder

func (*RestBuilder) WithStaticFilesFolder

func (rb *RestBuilder) WithStaticFilesFolder(uri, folder string) *RestBuilder

func (*RestBuilder) WithTLS

func (rb *RestBuilder) WithTLS(pem, key string) *RestBuilder

func (*RestBuilder) WithWriteTimeout

func (rb *RestBuilder) WithWriteTimeout(duration time.Duration) *RestBuilder