hashicorp

Mar 18, 2021

Changes in this version

+ type Publisher interface

+ Send func(data []machine.Data) error

+ type PublisherPlugin struct

+ Impl Publisher

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

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

+ type PublisherRPC struct

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

+ type PublisherRPCServer struct

+ Impl Publisher

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

Mar 12, 2021

Changes in this version

+ type Applicative interface

+ Applicative func(data machine.Data) error

+ type ApplicativePlugin struct

+ Impl Applicative

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

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

+ type ApplicativeRPC struct

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

+ type ApplicativeRPCServer struct

+ Impl Applicative

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

+ type Fold interface

+ Fold func(aggregate, data machine.Data) machine.Data

+ type FoldPlugin struct

+ Impl Fold

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

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

+ type FoldRPC struct

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

+ type FoldRPCServer struct

+ Impl Fold

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

+ type Fork interface

+ Fork func([]*machine.Packet) ([]*machine.Packet, []*machine.Packet)

+ type ForkPlugin struct

+ Impl Fork

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

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

+ type ForkRPC struct

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

+ type ForkRPCServer struct

+ Impl Fork

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

+ type Sender interface

+ Sender func(data []machine.Data) error

+ type SenderPlugin struct

+ Impl Sender

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

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

+ type SenderRPC struct

+ func (g *SenderRPC) Sender(data []machine.Data) error

+ type SenderRPCServer struct

+ Impl Sender

+ func (s *SenderRPCServer) Sender(args interface{}, resp *error) error

+ type SubscriptionPlugin struct

+ Impl machine.Subscription

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

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

+ type SubscriptionRPC struct

+ func (g *SubscriptionRPC) Close() error

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

+ type SubscriptionRPCServer struct

+ Impl machine.Subscription

+ func (s *SubscriptionRPCServer) Close() error

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