membrane

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Jul 14, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Membrane 

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

func New 

func New(options *MembraneOptions) (*Membrane, error)

Create a new Membrane server

func (*Membrane) Start 

func (s *Membrane) Start() error

Start the membrane

func (*Membrane) Stop 

func (s *Membrane) Stop()

type MembraneOptions 

type MembraneOptions struct {
	ServiceAddress string
	// The address the child will be listening on
	ChildAddress string
	// The command that will be used to invoke the child process
	ChildCommand []string
	// The total time to wait for the child process to be available in seconds
	ChildTimeoutSeconds int

	DocumentPlugin sdk.DocumentService
	EventingPlugin sdk.EventService
	KvPlugin       sdk.KeyValueService
	StoragePlugin  sdk.StorageService
	QueuePlugin    sdk.QueueService
	GatewayPlugin  sdk.GatewayService

	SuppressLogs            bool
	TolerateMissingServices bool

	// The operating mode of the membrane
	Mode *Mode

	// Supply your own worker pool
	Pool worker.WorkerPool
}

type Mode 

type Mode int

SourceType enum 

const (
	// Mode_Faas Facilitates FaaS via gRPC FaaS Server
	Mode_Faas Mode = iota
	// Mode_HttpFaas Facilitates FaaS via HTTP Request/Response
	Mode_HttpFaas
	// Mode_HttpProxy is designed for integration of monoliths into a nitric application
	Mode_HttpProxy
)

func ModeFromString 

func ModeFromString(modeString string) (Mode, error)

func (Mode) String 

func (m Mode) String() string

Source Files

View all Source files

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.