hashicorp

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

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

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

type PublisherPlugin

type PublisherPlugin struct {
	Impl Publisher
}

func (PublisherPlugin) Client

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

func (*PublisherPlugin) Server

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

type PublisherRPC

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

func (*PublisherRPC) Send

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

type PublisherRPCServer

type PublisherRPCServer struct {
	Impl Publisher
}

func (*PublisherRPCServer) Publisher

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