common

Documentation

Index

• func BindMinioPutEventChan(conn *nats.EncodedConn, eventChan chan *MinioPutEvent) (*nats.Subscription, error)
• func NewJSONEncodedNATSConn(serverURL string, seedFile string) (*nats.EncodedConn, error)
• type MinioPutEvent
  • func (e *MinioPutEvent) GetPackageName() string
• type Runner
  • func NewRunner(class string) (Runner, error)
• type StubRunner
  • func (r *StubRunner) Run(image string, env map[string]string, secrets []string, entry string)

Functions

func BindMinioPutEventChan

func BindMinioPutEventChan(conn *nats.EncodedConn, eventChan chan *MinioPutEvent) (*nats.Subscription, error)

func NewJSONEncodedNATSConn

func NewJSONEncodedNATSConn(serverURL string, seedFile string) (*nats.EncodedConn, error)

Types

type MinioPutEvent

type MinioPutEvent struct {
	Key string
}

func (*MinioPutEvent) GetPackageName

func (e *MinioPutEvent) GetPackageName() string

type Runner

type Runner interface {
	Run(image string, env map[string]string, secrets []string, entry string)
}

func NewRunner

func NewRunner(class string) (Runner, error)

type StubRunner

type StubRunner struct {
}

func (*StubRunner) Run

func (r *StubRunner) Run(image string, env map[string]string, secrets []string, entry string)