berlioz

package module
v0.0.0-...-f7ddbb8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 19, 2019 License: Apache-2.0 Imports: 34 Imported by: 0

README

Berlioz GoLang SDK

Using

Development

Running locally
$ berlioz local push-run
$ docker ps -a | grep berliozgo-example | awk '{print $1}' | xargs docker logs

Further launches can be made much quicker using:

berlioz local push-run --quick --cluster berliozgo --service example

berlioz local push-run --quick --cluster berliozgo --service example; docker ps -a | grep berliozgo-example | awk '{print $1}' | xargs docker logs

Helper script to run and fetch output

$ ./test-run.sh

cleanup:

berlioz local stop --cluster berliozgo

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetEnvironmentVariable 

func GetEnvironmentVariable(name string) string

TBD

func Identity 

func Identity() string

TBD

func WrapFunc 

func WrapFunc(h http.HandlerFunc) http.HandlerFunc

TBD

Types

type CloudResourceModel 

type CloudResourceModel struct {
	Name     string           `json:"name,omitempty"`
	Class    string           `json:"class,omitempty"`
	SubClass string           `json:"subClass,omitempty"`
	Config   cloudConfigModel `json:"config,omitempty"`
}

type CloudResourcesModel 

type CloudResourcesModel map[string]CloudResourceModel

type ClusterAccessor 

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

* SERVICE ACCESSOR

func Cluster 

func Cluster(name string) ClusterAccessor

TBD

func (ClusterAccessor) All 

func (x ClusterAccessor) All() map[string]interface{}

TBD

func (ClusterAccessor) Endpoint 

func (x ClusterAccessor) Endpoint(name string) ServiceEndpointAccessor

TBD

func (ClusterAccessor) First 

func (x ClusterAccessor) First() interface{}

TBD

func (ClusterAccessor) Get 

func (x ClusterAccessor) Get(identity string) interface{}

TBD

func (ClusterAccessor) MonitorAll 

func (x ClusterAccessor) MonitorAll(callback func(map[string]interface{})) SubscribeInfo

TBD

func (ClusterAccessor) MonitorFirst 

func (x ClusterAccessor) MonitorFirst(callback func(interface{})) SubscribeInfo

TBD

func (ClusterAccessor) Random 

func (x ClusterAccessor) Random() interface{}

TBD

func (ClusterAccessor) Request 

func (x ClusterAccessor) Request() PeerHttpRequester

TBD

type ConsumesAccessor 

type ConsumesAccessor struct {
}

* Consumes Accessor

func Consumes 

func Consumes() ConsumesAccessor

TBD

func (ConsumesAccessor) All 

func (x ConsumesAccessor) All() interface{}

TBD

func (ConsumesAccessor) MonitorAll 

func (x ConsumesAccessor) MonitorAll(callback func([]ConsumesModel)) SubscribeInfo

TBD

type ConsumesModel 

type ConsumesModel struct {
	Kind     string `json:"kind,omitempty"`
	ID       string `json:"id,omitempty"`
	Cluster  string `json:"cluster,omitempty"`
	Sector   string `json:"sector,omitempty"`
	Name     string `json:"name,omitempty"`
	Endpoint string `json:"endpoint,omitempty"`
	Meta     *bool  `json:"meta,omitempty"`
}

ConsumesModel is TBD.

type DynamoDBAccessor 

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

TBD

func (DynamoDBAccessor) Client 

func (x DynamoDBAccessor) Client(rawPeer interface{}) (*dynamodb.DynamoDB, *CloudResourceModel, error)

TBD

func (DynamoDBAccessor) CreateBackup 

func (x DynamoDBAccessor) CreateBackup(ctx context.Context, in1 *dynamodb.CreateBackupInput) (*dynamodb.CreateBackupOutput, error)

Wrapper for *dynamodb.DynamoDB::CreateBackup. 

In: , Type: *dynamodb.CreateBackupInput
Out: , Type: *dynamodb.CreateBackupOutput
Out: error, Type: error

func (DynamoDBAccessor) CreateTable 

func (x DynamoDBAccessor) CreateTable(ctx context.Context, in1 *dynamodb.CreateTableInput) (*dynamodb.CreateTableOutput, error)

Wrapper for *dynamodb.DynamoDB::CreateTable. 

In: , Type: *dynamodb.CreateTableInput
Out: , Type: *dynamodb.CreateTableOutput
Out: error, Type: error

func (DynamoDBAccessor) DeleteItem 

func (x DynamoDBAccessor) DeleteItem(ctx context.Context, in1 *dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error)

Wrapper for *dynamodb.DynamoDB::DeleteItem. 

In: , Type: *dynamodb.DeleteItemInput
Out: , Type: *dynamodb.DeleteItemOutput
Out: error, Type: error

func (DynamoDBAccessor) DeleteTable 

func (x DynamoDBAccessor) DeleteTable(ctx context.Context, in1 *dynamodb.DeleteTableInput) (*dynamodb.DeleteTableOutput, error)

Wrapper for *dynamodb.DynamoDB::DeleteTable. 

In: , Type: *dynamodb.DeleteTableInput
Out: , Type: *dynamodb.DeleteTableOutput
Out: error, Type: error

func (DynamoDBAccessor) DescribeContinuousBackups 

func (x DynamoDBAccessor) DescribeContinuousBackups(ctx context.Context, in1 *dynamodb.DescribeContinuousBackupsInput) (*dynamodb.DescribeContinuousBackupsOutput, error)

Wrapper for *dynamodb.DynamoDB::DescribeContinuousBackups. 

In: , Type: *dynamodb.DescribeContinuousBackupsInput
Out: , Type: *dynamodb.DescribeContinuousBackupsOutput
Out: error, Type: error

func (DynamoDBAccessor) DescribeTable 

func (x DynamoDBAccessor) DescribeTable(ctx context.Context, in1 *dynamodb.DescribeTableInput) (*dynamodb.DescribeTableOutput, error)

Wrapper for *dynamodb.DynamoDB::DescribeTable. 

In: , Type: *dynamodb.DescribeTableInput
Out: , Type: *dynamodb.DescribeTableOutput
Out: error, Type: error

func (DynamoDBAccessor) DescribeTimeToLive 

func (x DynamoDBAccessor) DescribeTimeToLive(ctx context.Context, in1 *dynamodb.DescribeTimeToLiveInput) (*dynamodb.DescribeTimeToLiveOutput, error)

Wrapper for *dynamodb.DynamoDB::DescribeTimeToLive. 

In: , Type: *dynamodb.DescribeTimeToLiveInput
Out: , Type: *dynamodb.DescribeTimeToLiveOutput
Out: error, Type: error

func (DynamoDBAccessor) GetItem 

func (x DynamoDBAccessor) GetItem(ctx context.Context, in1 *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error)

Wrapper for *dynamodb.DynamoDB::GetItem. 

In: , Type: *dynamodb.GetItemInput
Out: , Type: *dynamodb.GetItemOutput
Out: error, Type: error

func (DynamoDBAccessor) ListBackups 

func (x DynamoDBAccessor) ListBackups(ctx context.Context, in1 *dynamodb.ListBackupsInput) (*dynamodb.ListBackupsOutput, error)

Wrapper for *dynamodb.DynamoDB::ListBackups. 

In: , Type: *dynamodb.ListBackupsInput
Out: , Type: *dynamodb.ListBackupsOutput
Out: error, Type: error

func (DynamoDBAccessor) PutItem 

func (x DynamoDBAccessor) PutItem(ctx context.Context, in1 *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)

Wrapper for *dynamodb.DynamoDB::PutItem. 

In: , Type: *dynamodb.PutItemInput
Out: , Type: *dynamodb.PutItemOutput
Out: error, Type: error

func (DynamoDBAccessor) Query 

func (x DynamoDBAccessor) Query(ctx context.Context, in1 *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)

Wrapper for *dynamodb.DynamoDB::Query. 

In: , Type: *dynamodb.QueryInput
Out: , Type: *dynamodb.QueryOutput
Out: error, Type: error

func (DynamoDBAccessor) QueryPages 

func (x DynamoDBAccessor) QueryPages(ctx context.Context, in1 *dynamodb.QueryInput, in2 func(*dynamodb.QueryOutput, bool) bool) error

Wrapper for *dynamodb.DynamoDB::QueryPages. 

In: , Type: *dynamodb.QueryInput
In: , Type: func(*dynamodb.QueryOutput, bool) bool
Out: error, Type: error

func (DynamoDBAccessor) Scan 

func (x DynamoDBAccessor) Scan(ctx context.Context, in1 *dynamodb.ScanInput) (*dynamodb.ScanOutput, error)

Wrapper for *dynamodb.DynamoDB::Scan. 

In: , Type: *dynamodb.ScanInput
Out: , Type: *dynamodb.ScanOutput
Out: error, Type: error

func (DynamoDBAccessor) ScanPages 

func (x DynamoDBAccessor) ScanPages(ctx context.Context, in1 *dynamodb.ScanInput, in2 func(*dynamodb.ScanOutput, bool) bool) error

Wrapper for *dynamodb.DynamoDB::ScanPages. 

In: , Type: *dynamodb.ScanInput
In: , Type: func(*dynamodb.ScanOutput, bool) bool
Out: error, Type: error

func (DynamoDBAccessor) UpdateContinuousBackups 

func (x DynamoDBAccessor) UpdateContinuousBackups(ctx context.Context, in1 *dynamodb.UpdateContinuousBackupsInput) (*dynamodb.UpdateContinuousBackupsOutput, error)

Wrapper for *dynamodb.DynamoDB::UpdateContinuousBackups. 

In: , Type: *dynamodb.UpdateContinuousBackupsInput
Out: , Type: *dynamodb.UpdateContinuousBackupsOutput
Out: error, Type: error

func (DynamoDBAccessor) UpdateItem 

func (x DynamoDBAccessor) UpdateItem(ctx context.Context, in1 *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)

Wrapper for *dynamodb.DynamoDB::UpdateItem. 

In: , Type: *dynamodb.UpdateItemInput
Out: , Type: *dynamodb.UpdateItemOutput
Out: error, Type: error

func (DynamoDBAccessor) UpdateTable 

func (x DynamoDBAccessor) UpdateTable(ctx context.Context, in1 *dynamodb.UpdateTableInput) (*dynamodb.UpdateTableOutput, error)

Wrapper for *dynamodb.DynamoDB::UpdateTable. 

In: , Type: *dynamodb.UpdateTableInput
Out: , Type: *dynamodb.UpdateTableOutput
Out: error, Type: error

func (DynamoDBAccessor) UpdateTimeToLive 

func (x DynamoDBAccessor) UpdateTimeToLive(ctx context.Context, in1 *dynamodb.UpdateTimeToLiveInput) (*dynamodb.UpdateTimeToLiveOutput, error)

Wrapper for *dynamodb.DynamoDB::UpdateTimeToLive. 

In: , Type: *dynamodb.UpdateTimeToLiveInput
Out: , Type: *dynamodb.UpdateTimeToLiveOutput
Out: error, Type: error

func (DynamoDBAccessor) WaitUntilTableExists 

func (x DynamoDBAccessor) WaitUntilTableExists(ctx context.Context, in1 *dynamodb.DescribeTableInput) error

Wrapper for *dynamodb.DynamoDB::WaitUntilTableExists. 

In: , Type: *dynamodb.DescribeTableInput
Out: error, Type: error

func (DynamoDBAccessor) WaitUntilTableNotExists 

func (x DynamoDBAccessor) WaitUntilTableNotExists(ctx context.Context, in1 *dynamodb.DescribeTableInput) error

Wrapper for *dynamodb.DynamoDB::WaitUntilTableNotExists. 

In: , Type: *dynamodb.DescribeTableInput
Out: error, Type: error

type EndpointModel 

type EndpointModel struct {
	Name            string `json:"name,omitempty"`
	Protocol        string `json:"protocol,omitempty"`
	NetworkProtocol string `json:"networkProtocol,omitempty"`
	Port            uint16 `json:"port,omitempty"`
	Address         string `json:"address,omitempty"`
}

Endpoint is TBD.

func (EndpointModel) IsPresent 

func (x EndpointModel) IsPresent() bool

IsPresent TBD

type EndpointsModel 

type EndpointsModel map[string]PeersModel

type IndexedMap 

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

type MyEndpointAccessor 

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

* MY ENDPOINT ACCESSOR

func MyEndpoint 

func MyEndpoint(name string) MyEndpointAccessor

TBD

func (MyEndpointAccessor) Get 

func (x MyEndpointAccessor) Get() EndpointModel

TBD

func (MyEndpointAccessor) Monitor 

func (x MyEndpointAccessor) Monitor(callback func(EndpointModel))

TBD

type NativeResourceAccessor 

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

TBD

func Database 

func Database(name string) NativeResourceAccessor

TBD

func Queue 

func Queue(name string) NativeResourceAccessor

TBD

func (NativeResourceAccessor) All 

func (x NativeResourceAccessor) All() map[string]interface{}

TBD

func (NativeResourceAccessor) DynamoDB 

func (x NativeResourceAccessor) DynamoDB() DynamoDBAccessor

TBD

func (NativeResourceAccessor) First 

func (x NativeResourceAccessor) First() interface{}

TBD

func (NativeResourceAccessor) Get 

func (x NativeResourceAccessor) Get(identity string) interface{}

TBD

func (NativeResourceAccessor) MonitorAll 

func (x NativeResourceAccessor) MonitorAll(callback func(map[string]interface{})) SubscribeInfo

TBD

func (NativeResourceAccessor) MonitorFirst 

func (x NativeResourceAccessor) MonitorFirst(callback func(interface{})) SubscribeInfo

TBD

func (NativeResourceAccessor) Random 

func (x NativeResourceAccessor) Random() interface{}

TBD

func (NativeResourceAccessor) SSM 

func (x NativeResourceAccessor) SSM() SSMAccessor

TBD

type PeerAccessor 

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

* NEW Peer Accessor

func NewEndpointPeers 

func NewEndpointPeers(id string, endpoint string) PeerAccessor

TBD

func NewResourcePeers 

func NewResourcePeers(name string) PeerAccessor

TBD

func (PeerAccessor) All 

func (x PeerAccessor) All() map[string]interface{}

TBD

func (PeerAccessor) First 

func (x PeerAccessor) First() interface{}

TBD

func (PeerAccessor) Get 

func (x PeerAccessor) Get(identity string) interface{}

TBD

func (PeerAccessor) MonitorAll 

func (x PeerAccessor) MonitorAll(callback func(map[string]interface{})) SubscribeInfo

TBD

func (PeerAccessor) MonitorFirst 

func (x PeerAccessor) MonitorFirst(callback func(interface{})) SubscribeInfo

TBD

func (PeerAccessor) Random 

func (x PeerAccessor) Random() interface{}

TBD

type PeerHttpRequester 

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

TBD

func (PeerHttpRequester) Delete 

func (x PeerHttpRequester) Delete(ctx context.Context, url string, contentType string, body io.Reader) (*http.Response, []byte, error)

TBD

func (PeerHttpRequester) Do 

func (x PeerHttpRequester) Do(ctx context.Context, req *http.Request) (*http.Response, []byte, error)

TBD

func (PeerHttpRequester) Get 

func (x PeerHttpRequester) Get(ctx context.Context, url string) (*http.Response, []byte, error)

TBD

func (PeerHttpRequester) Head 

func (x PeerHttpRequester) Head(ctx context.Context, url string) (*http.Response, []byte, error)

TBD

func (PeerHttpRequester) Post 

func (x PeerHttpRequester) Post(ctx context.Context, url string, contentType string, body io.Reader) (*http.Response, []byte, error)

TBD

func (PeerHttpRequester) PostForm 

func (x PeerHttpRequester) PostForm(ctx context.Context, url string, data url.Values) (*http.Response, []byte, error)

TBD

type PeersModel 

type PeersModel map[string]EndpointModel

type ResourceModel 

type ResourceModel map[string]CloudResourceModel

type SSMAccessor 

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

TBD

func (SSMAccessor) Client 

func (x SSMAccessor) Client(rawPeer interface{}) (*ssm.SSM, *CloudResourceModel, error)

TBD

func (SSMAccessor) DeleteParameter 

func (x SSMAccessor) DeleteParameter(ctx context.Context, in0 *ssm.DeleteParameterInput) (*ssm.DeleteParameterOutput, error)

Wrapper for ssmiface.SSMAPI::DeleteParameter. 

In: , Type: *ssm.DeleteParameterInput
Out: , Type: *ssm.DeleteParameterOutput
Out: error, Type: error

func (SSMAccessor) GetParameter 

func (x SSMAccessor) GetParameter(ctx context.Context, in0 *ssm.GetParameterInput) (*ssm.GetParameterOutput, error)

Wrapper for ssmiface.SSMAPI::GetParameter. 

In: , Type: *ssm.GetParameterInput
Out: , Type: *ssm.GetParameterOutput
Out: error, Type: error

func (SSMAccessor) GetParameterHistory 

func (x SSMAccessor) GetParameterHistory(ctx context.Context, in0 *ssm.GetParameterHistoryInput) (*ssm.GetParameterHistoryOutput, error)

Wrapper for ssmiface.SSMAPI::GetParameterHistory. 

In: , Type: *ssm.GetParameterHistoryInput
Out: , Type: *ssm.GetParameterHistoryOutput
Out: error, Type: error

func (SSMAccessor) PutParameter 

func (x SSMAccessor) PutParameter(ctx context.Context, in0 *ssm.PutParameterInput) (*ssm.PutParameterOutput, error)

Wrapper for ssmiface.SSMAPI::PutParameter. 

In: , Type: *ssm.PutParameterInput
Out: , Type: *ssm.PutParameterOutput
Out: error, Type: error

type SecretAccessor 

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

TBD

func Secret 

func Secret(name string) SecretAccessor

TBD

func (SecretAccessor) Decrypt 

func (x SecretAccessor) Decrypt(ctx context.Context, data string) (string, error)

TBD

func (SecretAccessor) Encrypt 

func (x SecretAccessor) Encrypt(ctx context.Context, data string) (string, error)

TBD

type SectorAccessor 

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

* SECTOR ACCESSOR

func Sector 

func Sector(name string) SectorAccessor

TBD

func (SectorAccessor) Database 

func (x SectorAccessor) Database(name string) NativeResourceAccessor

TBD

func (SectorAccessor) Queue 

func (x SectorAccessor) Queue(name string) NativeResourceAccessor

TBD

func (SectorAccessor) Service 

func (x SectorAccessor) Service(name string) ServiceAccessor

TBD

type ServiceAccessor 

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

* SERVICE ACCESSOR

func Service 

func Service(name string) ServiceAccessor

TBD

func (ServiceAccessor) All 

func (x ServiceAccessor) All() map[string]interface{}

TBD

func (ServiceAccessor) Endpoint 

func (x ServiceAccessor) Endpoint(name string) ServiceEndpointAccessor

TBD

func (ServiceAccessor) First 

func (x ServiceAccessor) First() interface{}

TBD

func (ServiceAccessor) Get 

func (x ServiceAccessor) Get(identity string) interface{}

TBD

func (ServiceAccessor) MonitorAll 

func (x ServiceAccessor) MonitorAll(callback func(map[string]interface{})) SubscribeInfo

TBD

func (ServiceAccessor) MonitorFirst 

func (x ServiceAccessor) MonitorFirst(callback func(interface{})) SubscribeInfo

TBD

func (ServiceAccessor) Random 

func (x ServiceAccessor) Random() interface{}

TBD

func (ServiceAccessor) Request 

func (x ServiceAccessor) Request() PeerHttpRequester

TBD

type ServiceEndpointAccessor 

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

* SERVICE ENDPOINT ACCESSOR

func (ServiceEndpointAccessor) All 

func (x ServiceEndpointAccessor) All() map[string]interface{}

TBD

func (ServiceEndpointAccessor) First 

func (x ServiceEndpointAccessor) First() interface{}

TBD

func (ServiceEndpointAccessor) Get 

func (x ServiceEndpointAccessor) Get(identity string) interface{}

TBD

func (ServiceEndpointAccessor) MonitorAll 

func (x ServiceEndpointAccessor) MonitorAll(callback func(map[string]interface{})) SubscribeInfo

TBD

func (ServiceEndpointAccessor) MonitorFirst 

func (x ServiceEndpointAccessor) MonitorFirst(callback func(interface{})) SubscribeInfo

TBD

func (ServiceEndpointAccessor) Random 

func (x ServiceEndpointAccessor) Random() interface{}

TBD

func (ServiceEndpointAccessor) Request 

func (x ServiceEndpointAccessor) Request() PeerHttpRequester

TBD

type SubscribeInfo 

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

func (SubscribeInfo) Stop 

func (x SubscribeInfo) Stop()

type TracingSpan 

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

TBD

func (TracingSpan) Finish 

func (x TracingSpan) Finish()

TBD

Source Files

View all Source files

Directories

Path Synopsis
tools
codegen command

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.