hashicorp

package module

v0.18.0 Latest Latest Go to latest Published: Sep 14, 2021 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/whitaker-io/components

Documentation ¶

Index ¶

type Applicative
type ApplicativePlugin
- func (ApplicativePlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
- func (p *ApplicativePlugin) Server(*plugin.MuxBroker) (interface{}, error)
type ApplicativeRPC
- func (g *ApplicativeRPC) Applicative(data machine.Data) error
type ApplicativeRPCServer
- func (s *ApplicativeRPCServer) Applicative(args interface{}, resp *error) error
type Fold
type FoldPlugin
- func (FoldPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
- func (p *FoldPlugin) Server(*plugin.MuxBroker) (interface{}, error)
type FoldRPC
- func (g *FoldRPC) Fold(aggregate, data machine.Data) machine.Data
type FoldRPCServer
- func (s *FoldRPCServer) Fold(args interface{}, resp *machine.Data) error
type Fork
type ForkPlugin
- func (ForkPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
- func (p *ForkPlugin) Server(*plugin.MuxBroker) (interface{}, error)
type ForkRPC
- func (g *ForkRPC) Fork(list []*machine.Packet) ([]*machine.Packet, []*machine.Packet)
type ForkRPCServer
- func (s *ForkRPCServer) Fork(args interface{}, resp *[][]*machine.Packet) error
type Publisher
type PublisherPlugin
- func (PublisherPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
- func (p *PublisherPlugin) Server(*plugin.MuxBroker) (interface{}, error)
type PublisherRPC
- func (g *PublisherRPC) Send(data []machine.Data) error
type PublisherRPCServer
- func (s *PublisherRPCServer) Publisher(args interface{}, resp *error) error
type SubscriptionPlugin
- func (SubscriptionPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
- func (p *SubscriptionPlugin) Server(*plugin.MuxBroker) (interface{}, error)
type SubscriptionRPC
- func (g *SubscriptionRPC) Close() error
- func (g *SubscriptionRPC) Read(ctx context.Context) []machine.Data
type SubscriptionRPCServer
- func (s *SubscriptionRPCServer) Close() error
- func (s *SubscriptionRPCServer) Read(args interface{}, resp *[]machine.Data) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Applicative ¶

type Applicative interface {
	Applicative(data machine.Data) error
}

type ApplicativePlugin ¶

type ApplicativePlugin struct {
	Impl Applicative
}

func (ApplicativePlugin) Client ¶

func (ApplicativePlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (*ApplicativePlugin) Server ¶

func (p *ApplicativePlugin) Server(*plugin.MuxBroker) (interface{}, error)

type ApplicativeRPC ¶

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

func (*ApplicativeRPC) Applicative ¶

func (g *ApplicativeRPC) Applicative(data machine.Data) error

type ApplicativeRPCServer ¶

type ApplicativeRPCServer struct {
	Impl Applicative
}

func (*ApplicativeRPCServer) Applicative ¶

func (s *ApplicativeRPCServer) Applicative(args interface{}, resp *error) error

type Fold ¶

type Fold interface {
	Fold(aggregate, data machine.Data) machine.Data
}

type FoldPlugin ¶

type FoldPlugin struct {
	Impl Fold
}

func (FoldPlugin) Client ¶

func (FoldPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (*FoldPlugin) Server ¶

func (p *FoldPlugin) Server(*plugin.MuxBroker) (interface{}, error)

type FoldRPC ¶

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

func (*FoldRPC) Fold ¶

func (g *FoldRPC) Fold(aggregate, data machine.Data) machine.Data

type FoldRPCServer ¶

type FoldRPCServer struct {
	Impl Fold
}

func (*FoldRPCServer) Fold ¶

func (s *FoldRPCServer) Fold(args interface{}, resp *machine.Data) error

type Fork ¶

type Fork interface {
	Fork([]*machine.Packet) ([]*machine.Packet, []*machine.Packet)
}

type ForkPlugin ¶

type ForkPlugin struct {
	Impl Fork
}

func (ForkPlugin) Client ¶

func (ForkPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (*ForkPlugin) Server ¶

func (p *ForkPlugin) Server(*plugin.MuxBroker) (interface{}, error)

type ForkRPC ¶

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

func (*ForkRPC) Fork ¶

func (g *ForkRPC) Fork(list []*machine.Packet) ([]*machine.Packet, []*machine.Packet)

type ForkRPCServer ¶

type ForkRPCServer struct {
	Impl Fork
}

func (*ForkRPCServer) Fork ¶

func (s *ForkRPCServer) Fork(args interface{}, resp *[][]*machine.Packet) error

type Publisher ¶ added in v0.12.1

type Publisher interface {
	Send(data []machine.Data) error
}

type PublisherPlugin ¶ added in v0.12.1

type PublisherPlugin struct {
	Impl Publisher
}

func (PublisherPlugin) Client ¶ added in v0.12.1

func (PublisherPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (*PublisherPlugin) Server ¶ added in v0.12.1

func (p *PublisherPlugin) Server(*plugin.MuxBroker) (interface{}, error)

type PublisherRPC ¶ added in v0.12.1

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

func (*PublisherRPC) Send ¶ added in v0.12.1

func (g *PublisherRPC) Send(data []machine.Data) error

type PublisherRPCServer ¶ added in v0.12.1

type PublisherRPCServer struct {
	Impl Publisher
}

func (*PublisherRPCServer) Publisher ¶ added in v0.12.1

func (s *PublisherRPCServer) Publisher(args interface{}, resp *error) error

type SubscriptionPlugin ¶

type SubscriptionPlugin struct {
	Impl machine.Subscription
}

func (SubscriptionPlugin) Client ¶

func (SubscriptionPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (*SubscriptionPlugin) Server ¶

func (p *SubscriptionPlugin) Server(*plugin.MuxBroker) (interface{}, error)

type SubscriptionRPC ¶

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

func (*SubscriptionRPC) Close ¶

func (g *SubscriptionRPC) Close() error

func (*SubscriptionRPC) Read ¶

func (g *SubscriptionRPC) Read(ctx context.Context) []machine.Data

type SubscriptionRPCServer ¶

type SubscriptionRPCServer struct {
	Impl machine.Subscription
}

func (*SubscriptionRPCServer) Close ¶

func (s *SubscriptionRPCServer) Close() error

func (*SubscriptionRPCServer) Read ¶

func (s *SubscriptionRPCServer) Read(args interface{}, resp *[]machine.Data) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL