hashicorp

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

type ApplicativePlugin struct {
	Impl Applicative
}

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

type ApplicativeRPCServer struct {
	Impl Applicative
}

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

type FoldPlugin struct {
	Impl Fold
}

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

type FoldRPCServer struct {
	Impl Fold
}

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

type ForkPlugin struct {
	Impl Fork
}

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

type ForkRPCServer struct {
	Impl Fork
}

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

type PublisherPlugin struct {
	Impl Publisher
}

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

type PublisherRPCServer struct {
	Impl Publisher
}

type SubscriptionPlugin struct {
	Impl machine.Subscription
}

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

type SubscriptionRPCServer struct {
	Impl machine.Subscription
}