gsb

Oct 10, 2021

Changes in this version

+ func Errorf(error error) error

Sep 21, 2021

Changes in this version

+ type SnsMessage struct

+ Message string

+ func ParseIncomingSnsMessage(payload string) (*SnsMessage, error)

Sep 17, 2021

Changes in this version

+ type TestBus struct

+ SendList []TestEnvelope

+ func (tb *TestBus) AppVerboseLog(_ string)

+ func (tb *TestBus) Send(name string, payload string) error

+ type TestEnvelope struct

Sep 16, 2021

Changes in this version

+ func ParseIncomingMonitorMessage(payload string) (*gsb.MonitorData, error)

Sep 13, 2021

Changes in this version

type Bus

+ AppVerboseLog func(string)

Sep 13, 2021

Changes in this version

type Host

+ func (h *Host) AppVerboseLog(msg string)

Sep 1, 2021

Changes in this version

type Host

+ MqURL *url.URL

Aug 31, 2021

Changes in this version

+ type AppRes interface

+ Begin func() error

+ Commit func() error

+ Rollback func() error

type AppResBucket

+ func (b *AppResBucket) Begin() error

+ func (b *AppResBucket) Commit() error

+ func (b *AppResBucket) Rollback() error

type AppResDir

+ func (d *AppResDir) Begin() error

+ func (d *AppResDir) Commit() error

+ func (d *AppResDir) Rollback() error

type AppResDynamoDb

+ func (ddb *AppResDynamoDb) Begin() error

+ func (ddb *AppResDynamoDb) Commit() error

+ func (ddb *AppResDynamoDb) Rollback() error

type AppResFS

+ func (s *AppResFS) Begin() error

+ func (s *AppResFS) Commit() error

+ func (s *AppResFS) Rollback() error

type AppResInMemKeyVal

+ func (r *AppResInMemKeyVal) Begin() error

+ func (r *AppResInMemKeyVal) Commit() error

+ func (r *AppResInMemKeyVal) Rollback() error

type AppResQueueSqs

+ func (q *AppResQueueSqs) Begin() error

+ func (q *AppResQueueSqs) Rollback() error

type AppResRedis

+ func (r *AppResRedis) Begin() error

+ func (r *AppResRedis) Commit() error

+ func (r *AppResRedis) Rollback() error

type AppResS3

+ func (s *AppResS3) Begin() error

+ func (s *AppResS3) Commit() error

+ func (s *AppResS3) Rollback() error

+ type HandlerWrapper struct

type MqInMemory

+ func (mq *MqInMemory) Begin() error

+ func (mq *MqInMemory) Rollback() error

type MqInMemoryDynamoDb

+ func (ddb *MqInMemoryDynamoDb) Begin() error

+ func (ddb *MqInMemoryDynamoDb) Commit() error

+ func (ddb *MqInMemoryDynamoDb) Rollback() error

type QueueBeanstalk

+ func (q *QueueBeanstalk) Begin() error

+ func (q *QueueBeanstalk) Rollback() error

Aug 31, 2021

Changes in this version

type Host

+ Handler map[string]Handler

Aug 31, 2021

Changes in this version

+ type AppResInMemKeyVal struct

+ func NewAppResInMemKeyVal(url *url.URL) *AppResInMemKeyVal

+ func (r *AppResInMemKeyVal) Del(key string) error

+ func (r *AppResInMemKeyVal) Exists(key string) (bool, error)

+ func (r *AppResInMemKeyVal) Get(key string) (interface{}, error)

+ func (r *AppResInMemKeyVal) Init() error

+ func (r *AppResInMemKeyVal) Put(key string, item interface{}) error

Aug 30, 2021

Changes in this version

+ type Bus interface

+ GetDDb func(name string) (AppResDdb, error)

+ GetFileSystem func(name string) (*AppResFileSystem, error)

+ GetKeyVal func(name string) (*AppResKeyVal, error)

+ GetQueue func(name string) (*AppResQueue, error)

+ Send func(name string, payload string) error

type Handler

+ Handle func(payload string) error

+ Init func(bus Bus) error

type Host

+ func (h *Host) GetDDb(name string) (AppResDdb, error)

+ func (h *Host) GetFileSystem(name string) (*AppResFileSystem, error)

+ func (h *Host) GetKeyVal(name string) (*AppResKeyVal, error)

+ func (h *Host) GetQueue(name string) (*AppResQueue, error)

+ func (h *Host) Send(name string, payload string) error

type MessageSender

+ Send func(string, string) error

Aug 28, 2021

Changes in this version

+ func ResetMqInMemoryDynamoDb()

+ type AppResDdb interface

+ CreateTable func(input *dynamodb.CreateTableInput) error

+ Get func(tableName string, key map[string]string) (interface{}, error)

+ Init func() error

+ ListTables func() ([]string, error)

+ Put func(tableName string, item interface{}) error

+ type MqInMemoryDynamoDb struct

+ List []interface{}

+ TableNames []string

+ func NewMqInMemoryDynamoDb(url *url.URL) *MqInMemoryDynamoDb

+ func NewMqInMemoryDynamoDbFromString(urlString string) *MqInMemoryDynamoDb

+ func (ddb *MqInMemoryDynamoDb) CreateTable(input *dynamodb.CreateTableInput) error

+ func (ddb *MqInMemoryDynamoDb) Get(tableName string, key map[string]string) (interface{}, error)

+ func (ddb *MqInMemoryDynamoDb) ListTables() ([]string, error)

+ func (ddb *MqInMemoryDynamoDb) Put(tableName string, item interface{}) error

+ func (mq *MqInMemoryDynamoDb) Init() error

Aug 25, 2021

Changes in this version

type Host

+ func (h *Host) SendCommandToAudit(payload string)

Aug 24, 2021

Changes in this version

type Host

+ func (h *Host) ProcessCommand(cmd *string)

+ func (h *Host) VerboseLog(msg string)

Aug 23, 2021

Changes in this version

type Host

+ func (h *Host) SendEnvelope(q AppResQueue, env Envelope) error

+ func (h *Host) SendMessage2(q AppResQueue, name string, payload string) error

Aug 23, 2021

Changes in this version

+ type AppResBucket struct

+ func NewAppResBucket(url *url.URL) *AppResBucket

+ func (b *AppResBucket) Del(name string) error

+ func (b *AppResBucket) Exists(name string) (bool, error)

+ func (b *AppResBucket) Get(name string) (interface{}, error)

+ func (b *AppResBucket) Init() error

+ func (b *AppResBucket) Put(name string, item interface{}) error

Aug 23, 2021

Changes in this version

+ type MonitorQueue struct

+ Q Queue

+ func NewMonitorQueue(url *url.URL) *MonitorQueue

+ func (q *MonitorQueue) Commit() error

+ func (q *MonitorQueue) Init() error

+ func (q *MonitorQueue) Next() (*MonitorData, error)

Aug 20, 2021

Changes in this version

type AppResources

+ func (ar *AppResources) GetDDb(name string) (*AppResDynamoDb, error)

+ func (ar *AppResources) GetFileSystem(name string) (*AppResFileSystem, error)

+ func (ar *AppResources) GetKeyVal(name string) (*AppResKeyVal, error)

+ func (ar *AppResources) GetQueue(name string) (*AppResQueue, error)

Aug 20, 2021

Changes in this version

type AppResDir

+ func (dir *AppResDir) Exists(name string) (bool, error)

type AppResKeyVal

+ Exists func(key string) (bool, error)

type AppResRedis

+ func (r *AppResRedis) Exists(name string) (bool, error)

Aug 20, 2021

Changes in this version

+ func GetTimeoutFromUrl(qUrl *url.URL) (string, error)

Aug 20, 2021

Changes in this version

type AppResDynamoDb

+ func (ddb *AppResDynamoDb) ListTables() ([]string, error)

Aug 20, 2021

Changes in this version

+ func AwsSetQueueTimeout(svc *sqs.Client, envUrl *url.URL, queueUrl *string) error

type AppResDynamoDb

+ func (ddb *AppResDynamoDb) CreateTable(input *dynamodb.CreateTableInput) error

type AppResQueueSqs

+ func (q *AppResQueueSqs) CreateQueue()

type Envelope

+ func (env *Envelope) AddError(error string)

+ type EnvelopeError struct

+ Error string

+ Timestamp time.Time

type Host

+ AuditQ Queue

+ func (h *Host) InitAuditQueue()

+ func (h *Host) SendToAudit(env Envelope)

Aug 19, 2021

Changes in this version

+ type AppResQueueSqs struct

+ func NewAppResQueueSqs(url *url.URL) *AppResQueueSqs

+ func (q *AppResQueueSqs) Commit() error

+ func (q *AppResQueueSqs) GetQueueUrl(queueName string) (*sqs.GetQueueUrlOutput, error)

+ func (q *AppResQueueSqs) Init() error

+ func (q *AppResQueueSqs) Name() string

+ func (q *AppResQueueSqs) Retrieve() (*string, error)

+ func (q *AppResQueueSqs) Send(Message string) error

Aug 19, 2021

Changes in this version

+ func NewAwsConfig() aws.Config

Aug 18, 2021

Changes in this version

type AppResources

+ func (ar *AppResources) LoadAppResources(gsbEnvVars []GsbEnvVar)

type GsbEnvVar

+ func LoadGsbEnvVars(prefix string) []GsbEnvVar

type Host

+ LocalSendQ Queue

+ func (h *Host) SendMessage(name string, payload string)

+ type MessageSender interface

+ SendMessage func(string, string)

+ type Monitor interface

+ Commit func() error

+ Init func() error

+ Next func() (*MonitorData, error)

+ type MonitorData struct

+ Name string

+ Payload string

+ type MonitorDir struct

+ func NewMonitorDir(url *url.URL) *MonitorDir

+ func (dir *MonitorDir) Commit() error

+ func (dir *MonitorDir) Init() error

+ func (dir *MonitorDir) Next() (*MonitorData, error)

+ type Monitors struct

+ func NewMonitors() *Monitors

+ func (m *Monitors) Init(messageSender MessageSender)

+ func (m *Monitors) LoadMonitors(gsbEnvVars []GsbEnvVar)

+ func (m *Monitors) Process()

Aug 16, 2021

Changes in this version

+ func ResetMqInMemory()

+ func SendEnvelope(q AppResQueue, env Envelope) error

+ func SendMessage(q AppResQueue, name string, payload string) error

+ type AppResDDb interface

+ Get func(tableName string, key map[string]string) (interface{}, error)

+ Init func() error

+ Put func(tableName string, item interface{}) error

+ type AppResDir struct

+ func NewAppResDir(url *url.URL) *AppResDir

+ func (dir *AppResDir) Del(name string) error

+ func (dir *AppResDir) Get(name string) (interface{}, error)

+ func (dir *AppResDir) Init() error

+ func (dir *AppResDir) Put(name string, item interface{}) error

+ type AppResDynamoDb struct

+ func NewAppResDynamoDb(url *url.URL) *AppResDynamoDb

+ func (ddb *AppResDynamoDb) Get(tableName string, key map[string]string) (interface{}, error)

+ func (ddb *AppResDynamoDb) Init() error

+ func (ddb *AppResDynamoDb) Put(tableName string, item interface{}) error

+ type AppResFS struct

+ func NewAppResFS(url *url.URL) *AppResFS

+ func (fs *AppResFS) Init() error

+ func (s *AppResFS) Del(path string, name string) error

+ func (s *AppResFS) Get(path string, name string) ([]byte, error)

+ func (s *AppResFS) Put(path string, name string, payload []byte) error

+ type AppResFileSystem interface

+ Del func(path string, name string) error

+ Get func(path string, name string) ([]byte, error)

+ Init func() error

+ Put func(path string, name string, payload []byte) error

+ type AppResKeyVal interface

+ Del func(key string) error

+ Get func(key string) (interface{}, error)

+ Init func() error

+ Put func(key string, item interface{}) error

+ type AppResQueue interface

+ Commit func() error

+ Init func() error

+ Name func() string

+ Retrieve func() (*string, error)

+ Send func(payload string) error

+ type AppResQueueAws struct

+ func NewAppResQueueAws(url *url.URL) *AppResQueueAws

+ func (q *AppResQueueAws) Commit() error

+ func (q *AppResQueueAws) GetQueueUrl(queueName string) (*sqs.GetQueueUrlOutput, error)

+ func (q *AppResQueueAws) Init() error

+ func (q *AppResQueueAws) Name() string

+ func (q *AppResQueueAws) Retrieve() (*string, error)

+ func (q *AppResQueueAws) Send(Message string) error

+ type AppResRedis struct

+ func NewAppResRedis(url *url.URL) *AppResRedis

+ func (r *AppResRedis) Del(key string) error

+ func (r *AppResRedis) Get(key string) (interface{}, error)

+ func (r *AppResRedis) Init() error

+ func (r *AppResRedis) Put(key string, item interface{}) error

+ type AppResS3 struct

+ func NewAppResS3(url *url.URL) *AppResS3

+ func (s *AppResS3) Del(path string, name string) error

+ func (s *AppResS3) Get(path string, name string) ([]byte, error)

+ func (s *AppResS3) Init() error

+ func (s *AppResS3) Put(path string, name string, payload []byte) error

+ type AppResources struct

+ DDb map[string]AppResDDb

+ FileSystem map[string]AppResFileSystem

+ KeyVal map[string]AppResKeyVal

+ Queue map[string]AppResQueue

+ func NewAppResources() *AppResources

+ func (ar *AppResources) GetGSBEnvVars() []string

+ func (ar *AppResources) Init()

+ func (ar *AppResources) ProcessEnvVar(gsbEnvVarStr string) GsbEnvVar

+ func (ar *AppResources) ProcessEnvVars(gsbEnvVarStrs []string)

+ type Envelope struct

+ Errors []string

+ Identifier string

+ Msg string

+ Name string

+ OriginalQueueName string

+ func NewEnvelope(QueueName, Name, Message string) (Envelope, error)

+ func UnmarshalEnvelope(payload []byte) (*Envelope, error)

+ func (env *Envelope) Marshal() ([]byte, error)

+ type GsbEnvVar struct

+ type Handler struct

+ Fn HandlerFn

+ Name string

+ type HandlerFn func(*HandlerState, string) error

+ type HandlerState struct

+ AppResources *AppResources

+ Keys map[string]string

+ func NewHandlerState(appResources *AppResources) *HandlerState

+ func (hs *HandlerState) Send(queueName string, name string, payload string) error

+ type Host struct

+ ErrorQ Queue

+ Handlers []Handler

+ Mq Mq

+ MqUrl *url.URL

+ Name string

+ func NewHost() *Host

+ func (h *Host) AddHandler(name string, f HandlerFn)

+ func (h *Host) Init()

+ func (h *Host) InitErrorQueue()

+ func (h *Host) InitMq()

+ func (h *Host) MqCommit() error

+ func (h *Host) MqRetrieve() *Envelope

+ func (h *Host) ProcessError(env *Envelope, err error)

+ func (h *Host) ProcessHandlers(env *Envelope) error

+ func (h *Host) ProcessMessage(env *Envelope)

+ func (h *Host) Run()

+ func (h *Host) Tick()

+ type Mq interface

+ Commit func() error

+ Init func() error

+ Retrieve func() (*string, error)

+ type MqAws struct

+ func NewMqAws(url *url.URL) *MqAws

+ func (mq *MqAws) Commit() error

+ func (mq *MqAws) Init() error

+ func (mq *MqAws) Retrieve() (*string, error)

+ type MqBeanstalk struct

+ func NewMqBeanstalk(url *url.URL) *MqBeanstalk

+ func (mq *MqBeanstalk) Commit() error

+ func (mq *MqBeanstalk) Init() error

+ func (mq *MqBeanstalk) Retrieve() (*string, error)

+ type MqInMemory struct

+ List []string

+ func NewMqInMemory(url *url.URL) *MqInMemory

+ func NewMqInMemoryFromString(urlString string) *MqInMemory

+ func (mq *MqInMemory) Commit() error

+ func (mq *MqInMemory) Init() error

+ func (mq *MqInMemory) Move(fromS string, toS string)

+ func (mq *MqInMemory) Name() string

+ func (mq *MqInMemory) Retrieve() (*string, error)

+ func (mq *MqInMemory) Send(payload string) error

+ type Queue interface

+ Commit func() error

+ Init func() error

+ Name func() string

+ Retrieve func() (*string, error)

+ Send func(payload string) error

+ func NewQueue(urlString string) Queue

+ type QueueBeanstalk struct

+ func NewAppResQueueBeanstalk(url *url.URL) *QueueBeanstalk

+ func (q *QueueBeanstalk) Commit() error

+ func (q *QueueBeanstalk) Init() error

+ func (q *QueueBeanstalk) Name() string

+ func (q *QueueBeanstalk) Retrieve() (*string, error)

+ func (q *QueueBeanstalk) Send(payload string) error