sbsdk

package

Go to main page

Versions in this module

v0

v0.0.7

Sep 5, 2023

Changes in this version

+ func MapCtyValueToByteString(val cty.Value, outputType Type) ([]byte, error)

+ func MapInputToCtyValue(input []byte, schema ObjectSchema) (cty.Value, error)

v0.0.6

Aug 30, 2023

Changes in this version

type Action

+ ConfigurationSchema func() (ObjectSchema, error)

+ OutputType func() (Type, error)

type Provider

+ MapPayloadToTriggerKey func([]byte) (string, error)

+ TriggerKeyNames func() ([]string, error)

type ProviderRPCClient

+ func (p *ProviderRPCClient) MapPayloadToTriggerKey(data []byte) (string, error)

+ func (p *ProviderRPCClient) TriggerKeyNames() ([]string, error)

type Trigger

+ ConfigurationSchema func() (ObjectSchema, error)

v0.0.5

Aug 21, 2023

Changes in this version

+ const DYNAMIC_TYPE

+ const TYPE_INTERNAL_TYPE_KEY

+ const TYPE_NAME_KEY

+ const TYPE_NESTED_VALUES_KEY

+ type ActionEvalData struct

+ ContextId string

+ Input []byte

+ Name string

+ type GlobalConfig struct

+ PrivateIngestUri string

+ PublicIngestUri string

+ type InitData struct

+ GlobalConfig GlobalConfig

+ UserConfig []byte

type Provider

+ CreateSubscription func(contextId string, input []byte) ([]byte, error)

+ DeleteSubscription func(contextId string, subscriptionId string) error

+ MapPayloadToTrigger func([]byte) (string, error)

+ ReadSubscription func(contextId string, subscriptionId string) ([]byte, error)

+ TriggerConfigurationSchema func(name string) (ObjectSchema, error)

+ TriggerNames func() ([]string, error)

+ TriggerOutputType func(name string) (Type, error)

+ UpdateSubscription func(contextId string, subscriptionId string, input []byte) ([]byte, error)

+ type ProviderConfig struct

+ SubscriptionsRegisteredTogether bool

type ProviderRPCClient

+ func (p *ProviderRPCClient) CreateSubscription(contextId string, input []byte) ([]byte, error)

+ func (p *ProviderRPCClient) DeleteSubscription(contextId string, subscriptionId string) error

+ func (p *ProviderRPCClient) MapPayloadToTrigger(data []byte) (string, error)

+ func (p *ProviderRPCClient) ReadSubscription(contextId string, subscriptionId string) ([]byte, error)

+ func (p *ProviderRPCClient) TriggerConfigurationSchema(name string) (ObjectSchema, error)

+ func (p *ProviderRPCClient) TriggerNames() ([]string, error)

+ func (p *ProviderRPCClient) TriggerOutputType(name string) (Type, error)

+ func (p *ProviderRPCClient) UpdateSubscription(contextId string, subscriptionId string, input []byte) ([]byte, error)

type ProviderRPCServer

+ func (p *ProviderRPCServer) CreateSubscription(data SubscriptionData, reply *[]byte) error

+ func (p *ProviderRPCServer) DeleteSubscription(data SubscriptionData) error

+ func (p *ProviderRPCServer) MapPayloadToTrigger(data []byte, reply *string) error

+ func (p *ProviderRPCServer) ReadSubscription(data SubscriptionData, reply *[]byte) error

+ func (p *ProviderRPCServer) TriggerConfigurationSchema(name string, reply *ObjectSchema) error

+ func (p *ProviderRPCServer) TriggerNames(_ any, reply *[]string) error

+ func (p *ProviderRPCServer) TriggerOutputType(name string, reply *Type) error

+ func (p *ProviderRPCServer) UpdateSubscription(data SubscriptionData, reply *[]byte) error

+ type RunnerProvider interface

+ GlobalConfig func() GlobalConfig

+ UserConfig func(contextId string) []byte

+ type SubscriptionData struct

+ ContextId string

+ InputData []byte

+ SubscriptionId string

type Type

+ TypeName string

+ var Dynamic Type

+ func FromCtyToType(val cty.Value, isRoot bool) (*Type, error)

v0.0.4

Mar 12, 2023

Changes in this version

+ var HandshakeConfig = plugin.HandshakeConfig

v0.0.3

Mar 11, 2023

Changes in this version

+ const BOOLEAN_TYPE

+ const INVALID_TYPE

+ const LIST_TYPE

+ const MAP_TYPE

+ const NUMBER_TYPE

+ const OBJECT_TYPE

+ const STRING_TYPE

+ func InvokeActionEvaluation(action Action, p Provider, name string, config []byte, input []byte) ([]byte, error)

+ func MarshalVal(schema Schema, val cty.Value) ([]byte, error)

+ func UnmarshalVal(schema Schema, data []byte) (cty.Value, error)

+ type Action interface

+ Evaluate func(config cty.Value, input cty.Value) (cty.Value, error)

+ type AttrSchema struct

+ Name string

+ Required bool

+ Type Type

+ func OptionalAttrSchema(name string, valType Type) *AttrSchema

+ func RequiredAttrSchema(name string, valType Type) *AttrSchema

+ func (b *AttrSchema) Decode() hcldec.Spec

+ type BlockSchema struct

+ Name string

+ Nested Schema

+ Required bool

+ func OptionalBlockSchema(name string, nested Schema) *BlockSchema

+ func (b *BlockSchema) Decode() hcldec.Spec

+ type EvaluateServerPayload struct

+ Config []byte

+ Input []byte

+ Name string

+ type Function interface

+ ConfigurationSchema func() (ObjectSchema, error)

+ OutputType func() (Type, error)

+ type ObjectSchema map[string]Schema

+ func (s *ObjectSchema) Decode() hcldec.Spec

+ type Provider interface

+ ActionConfigurationSchema func(name string) (ObjectSchema, error)

+ ActionEvaluate func(name string, config []byte, input []byte) ([]byte, error)

+ ActionNames func() ([]string, error)

+ ActionOutputType func(name string) (Type, error)

+ Init func([]byte) error

+ InitSchema func() (ObjectSchema, error)

+ func NewProviderRPCClient() Provider

+ type ProviderPlugin struct

+ Impl Provider

+ func (p *ProviderPlugin) Client(_ *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

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

+ type ProviderRPCClient struct

+ func (p *ProviderRPCClient) ActionConfigurationSchema(name string) (ObjectSchema, error)

+ func (p *ProviderRPCClient) ActionEvaluate(name string, config []byte, input []byte) ([]byte, error)

+ func (p *ProviderRPCClient) ActionNames() ([]string, error)

+ func (p *ProviderRPCClient) ActionOutputType(name string) (Type, error)

+ func (p *ProviderRPCClient) Init(val []byte) error

+ func (p *ProviderRPCClient) InitSchema() (ObjectSchema, error)

+ type ProviderRPCServer struct

+ Impl Provider

+ func (p *ProviderRPCServer) ActionConfigurationSchema(name string, reply *ObjectSchema) error

+ func (p *ProviderRPCServer) ActionEvaluate(payload EvaluateServerPayload, reply *[]byte) error

+ func (p *ProviderRPCServer) ActionNames(_ any, reply *[]string) error

+ func (p *ProviderRPCServer) ActionOutputType(name string, reply *Type) error

+ func (p *ProviderRPCServer) Init(val []byte, _ *any) error

+ func (p *ProviderRPCServer) InitSchema(_ any, reply *ObjectSchema) error

+ type Schema interface

+ Decode func() hcldec.Spec

+ type Trigger interface

+ IsRegistered func(config cty.Value, input cty.Value) (bool, error)

+ Listen func(cb func(output cty.Value)) error

+ Register func(config cty.Value, input cty.Value) (string, error)

+ ShouldListen func() (bool, error)

+ Unregister func(config cty.Value, input cty.Value) (string, error)

+ type Type struct

+ InternalType *Type

+ Name string

+ NestedValues *map[string]Type

+ var Bool Type

+ var Invalid Type

+ var Number Type

+ var String Type

+ func List(valType Type) Type

+ func Map(valType Type) Type

+ func Object(data map[string]Type) Type

+ func (t *Type) ToCty() cty.Type

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