sdktypes

package
v0.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 28, 2024 License: Apache-2.0 Imports: 53 Imported by: 0

Documentation

Overview

Package sdktypes contains all the data types used by the autokitteh SDK.

All the types represent data structures that are defined in the proto package. The underlying data is either a protobuf message or a primitive that can be set as a field in other messages. The main idea is that it should be impossible to have a object that contains a malform/unvalidated values. An object is either valid with valid information, or invalid with a nil message.

There are three main types of underlying data:

  1. Messages, which are also called "objects" here, which are structs that contain other fields. These are implemented using the `object` struct. Examples: Project, Session, etc.
  2. Validated strings, which are Names and Symbols, implemented using the `validatedString` struct. Examples: Name and Symbol.
  3. Enumerations, which are implemented using the `enum` struct. Examples: DeployentState, SessionStateType, etc.

Specific objects are defined like so:

  type Project struct { object[pb.Project, projectTraits] }
  type projectTraits struct {}
  func (projectTraits) Validate(m *pb.Project) error {
    // Validates all fields are correct. Each field is permitted to be empty.
	 }
  func (projectTraits) StrictValidate(m *pb.Project) error {
    // Validates all mandatory fields are specified.
  }

IDs and Names are kind of the same thing, but with different types. See examples mentioned above for more information.

Index

Constants

View Source
const ValidIDChars = "0123456789abcdefghjkmnpqrstvwxyz"

Variables

View Source
var (
	PossibleDeploymentStatesNames = AllEnumNames[deploymentStateTraits]()

	DeploymentStateUnspecified = deploymentStateFromProto(deploymentsv1.DeploymentState_DEPLOYMENT_STATE_UNSPECIFIED)
	DeploymentStateActive      = deploymentStateFromProto(deploymentsv1.DeploymentState_DEPLOYMENT_STATE_ACTIVE)
	DeploymentStateDraining    = deploymentStateFromProto(deploymentsv1.DeploymentState_DEPLOYMENT_STATE_DRAINING)
	DeploymentStateInactive    = deploymentStateFromProto(deploymentsv1.DeploymentState_DEPLOYMENT_STATE_INACTIVE)
	DeploymentStateTesting     = deploymentStateFromProto(deploymentsv1.DeploymentState_DEPLOYMENT_STATE_TESTING)
)
View Source
var (
	PossibleEventStatesNames = AllEnumNames[eventStateTraits]()

	EventStateUnspecified = eventStateFromProto(eventsv1.EventState_EVENT_STATE_UNSPECIFIED)
	EventStateSaved       = eventStateFromProto(eventsv1.EventState_EVENT_STATE_SAVED)
	EventStateProcessing  = eventStateFromProto(eventsv1.EventState_EVENT_STATE_PROCESSING)
	EventStateCompleted   = eventStateFromProto(eventsv1.EventState_EVENT_STATE_COMPLETED)
	EventStateFailed      = eventStateFromProto(eventsv1.EventState_EVENT_STATE_FAILED)
)
View Source
var (
	PossibleSessionStateTypesNames = AllEnumNames[sessionStateTypeTraits]()

	SessionStateTypeUnspecified = sessionStateTypeFromProto(sessionsv1.SessionStateType_SESSION_STATE_TYPE_UNSPECIFIED)
	SessionStateTypeCreated     = sessionStateTypeFromProto(sessionsv1.SessionStateType_SESSION_STATE_TYPE_CREATED)
	SessionStateTypeRunning     = sessionStateTypeFromProto(sessionsv1.SessionStateType_SESSION_STATE_TYPE_RUNNING)
	SessionStateTypeError       = sessionStateTypeFromProto(sessionsv1.SessionStateType_SESSION_STATE_TYPE_ERROR)
	SessionStateTypeCompleted   = sessionStateTypeFromProto(sessionsv1.SessionStateType_SESSION_STATE_TYPE_COMPLETED)
	SessionStateTypeStopped     = sessionStateTypeFromProto(sessionsv1.SessionStateType_SESSION_STATE_TYPE_STOPPED)
)
View Source
var (
	PossibleStatusCodesNames = AllEnumNames[statusCodeTraits]()

	StatusCodeUnspecified = statusCodeFromProto(commonv1.Status_CODE_UNSPECIFIED)
	StatusCodeOK          = statusCodeFromProto(commonv1.Status_CODE_OK)
	StatusCodeWarning     = statusCodeFromProto(commonv1.Status_CODE_WARNING)
	StatusCodeError       = statusCodeFromProto(commonv1.Status_CODE_ERROR)
)
View Source
var BuiltinSchedulerConnectionID = kittehs.Must1(ParseConnectionID("con_3kthcr0n000000000000000000"))

REVIEW: we cannot define this in fixtures, due to circular dependencies

View Source
var Nothing = forceFromProto[Value](&ValuePB{Nothing: &NothingValuePB{}})

Functions

func AllEnumNames added in v0.3.0

func AllEnumNames[T enumTraits]() (values []string)

func EnumFromProto added in v0.3.0

func EnumFromProto[W ~struct{ enum[T, E] }, T enumTraits, E ~int32](e E) (w W, err error)

func FromProto added in v0.3.0

func FromProto[W ~struct{ object[M, T] }, M comparableMessage, T objectTraits[M]](m M) (w W, err error)

func IsConcreteValue added in v0.3.0

func IsConcreteValue(x any) bool

func IsConnectionID added in v0.3.0

func IsConnectionID(s string) bool

func IsEnvID added in v0.3.0

func IsEnvID(s string) bool

func IsID

func IsID(s string) bool

func IsIDOf added in v0.3.0

func IsIDOf[T idTraits](s string) bool

func IsIntegrationID added in v0.3.0

func IsIntegrationID(s string) bool

func IsProjectID added in v0.3.0

func IsProjectID(s string) bool

func IsValid added in v0.3.0

func IsValid[V isValider](v V) bool

func IsValidSymbol added in v0.3.0

func IsValidSymbol(s string) bool

func NewIDFromUUID added in v0.4.6

func NewIDFromUUID[ID id[T], T idTraits](uuid *UUID) ID

func NewSequentialIDGeneratorForTesting

func NewSequentialIDGeneratorForTesting(init uint64) func() UUID

To be used for testing only, when we expect a certain ID. First ID generated will be init+1.

func ParseEnum added in v0.3.0

func ParseEnum[W ~struct{ enum[T, E] }, T enumTraits, E ~int32](raw string) (w W, err error)

func ParseID added in v0.3.0

func ParseID[ID id[T], T idTraits](s string) (ID, error)

func ParseValidatedString added in v0.3.0

func ParseValidatedString[N ~struct{ validatedString[T] }, T validatedStringTraits](v string) (n N, err error)

func SetIDGenerator

func SetIDGenerator(f func() UUID)

func Strict added in v0.3.0

func Strict[T stricter](t T, err error) (T, error)

func ToProto

func ToProto[O interface{ ToProto() M }, M proto.Message](o O) M

func ToString added in v0.3.0

func ToString(o fmt.Stringer) string

func UnwrapValue added in v0.3.0

func UnwrapValue(v Value) (any, error)

func UnwrapValueInto added in v0.3.2

func UnwrapValueInto(dst any, v Value) error

func VerifyEventFilter added in v0.6.3

func VerifyEventFilter(filter string) error

Types

type BooleanValue

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

func (BooleanValue) Equal added in v0.3.0

func (o BooleanValue) Equal(other interface{ ToProto() M }) bool

func (BooleanValue) Hash added in v0.3.0

func (o BooleanValue) Hash() string

func (BooleanValue) IsValid added in v0.3.0

func (o BooleanValue) IsValid() bool

func (BooleanValue) MarshalJSON added in v0.3.0

func (o BooleanValue) MarshalJSON() ([]byte, error)

func (BooleanValue) Message added in v0.3.0

func (o BooleanValue) Message() proto.Message

func (BooleanValue) Strict added in v0.3.0

func (o BooleanValue) Strict() error

func (BooleanValue) String added in v0.3.0

func (o BooleanValue) String() string

func (BooleanValue) ToProto added in v0.3.0

func (o BooleanValue) ToProto() M

func (*BooleanValue) UnmarshalJSON added in v0.3.0

func (o *BooleanValue) UnmarshalJSON(b []byte) (err error)

func (BooleanValue) Value added in v0.3.0

func (s BooleanValue) Value() bool

type BooleanValuePB added in v0.3.0

type BooleanValuePB = valuev1.Boolean

type Build

type Build struct {
	// contains filtered or unexported fields
}
var InvalidBuild Build

func BuildFromProto

func BuildFromProto(m *BuildPB) (Build, error)

func NewBuild added in v0.2.0

func NewBuild() Build

func StrictBuildFromProto

func StrictBuildFromProto(m *BuildPB) (Build, error)

func (Build) CreatedAt added in v0.3.0

func (p Build) CreatedAt() time.Time

func (Build) Equal added in v0.3.0

func (o Build) Equal(other interface{ ToProto() M }) bool

func (Build) Hash added in v0.3.0

func (o Build) Hash() string

func (Build) ID added in v0.3.0

func (p Build) ID() (_ BuildID)

func (Build) IsValid added in v0.3.0

func (o Build) IsValid() bool

func (Build) MarshalJSON added in v0.3.0

func (o Build) MarshalJSON() ([]byte, error)

func (Build) Message added in v0.3.0

func (o Build) Message() proto.Message

func (Build) ProjectID added in v0.7.1

func (p Build) ProjectID() (_ ProjectID)

func (Build) Strict added in v0.3.0

func (o Build) Strict() error

func (Build) String added in v0.3.0

func (o Build) String() string

func (Build) ToProto added in v0.3.0

func (o Build) ToProto() M

func (*Build) UnmarshalJSON added in v0.3.0

func (o *Build) UnmarshalJSON(b []byte) (err error)

func (Build) WithCreatedAt added in v0.3.0

func (p Build) WithCreatedAt(t time.Time) Build

func (Build) WithNewID added in v0.3.0

func (p Build) WithNewID() Build

func (Build) WithProjectID added in v0.7.1

func (p Build) WithProjectID(pid ProjectID) Build

type BuildArtifact

type BuildArtifact struct {
	// contains filtered or unexported fields
}
var InvalidBuildArtifact BuildArtifact

func BuildArtifactFromProto

func BuildArtifactFromProto(m *BuildArtifactPB) (BuildArtifact, error)

func (BuildArtifact) CompiledData added in v0.3.0

func (a BuildArtifact) CompiledData() map[string][]byte

func (BuildArtifact) Equal added in v0.3.0

func (o BuildArtifact) Equal(other interface{ ToProto() M }) bool

func (BuildArtifact) Exports added in v0.3.0

func (a BuildArtifact) Exports() []BuildExport

func (BuildArtifact) Hash added in v0.3.0

func (o BuildArtifact) Hash() string

func (BuildArtifact) IsValid added in v0.3.0

func (o BuildArtifact) IsValid() bool

func (BuildArtifact) MarshalJSON added in v0.3.0

func (o BuildArtifact) MarshalJSON() ([]byte, error)

func (BuildArtifact) MergeFrom added in v0.3.0

func (r BuildArtifact) MergeFrom(other BuildArtifact) BuildArtifact

func (BuildArtifact) Message added in v0.3.0

func (o BuildArtifact) Message() proto.Message

func (BuildArtifact) Requirements added in v0.3.0

func (a BuildArtifact) Requirements() []BuildRequirement

func (BuildArtifact) Strict added in v0.3.0

func (o BuildArtifact) Strict() error

func (BuildArtifact) String added in v0.3.0

func (o BuildArtifact) String() string

func (BuildArtifact) ToProto added in v0.3.0

func (o BuildArtifact) ToProto() M

func (*BuildArtifact) UnmarshalJSON added in v0.3.0

func (o *BuildArtifact) UnmarshalJSON(b []byte) (err error)

func (BuildArtifact) WithCompiledData added in v0.3.0

func (r BuildArtifact) WithCompiledData(data map[string][]byte) BuildArtifact

func (BuildArtifact) WithExports added in v0.3.0

func (r BuildArtifact) WithExports(exports []BuildExport) BuildArtifact

func (BuildArtifact) WithRequirements added in v0.3.0

func (r BuildArtifact) WithRequirements(reqs []BuildRequirement) BuildArtifact

type BuildArtifactPB

type BuildArtifactPB = runtimesv1.Artifact

type BuildArtifactTraits added in v0.3.0

type BuildArtifactTraits struct{}

func (BuildArtifactTraits) StrictValidate added in v0.3.0

func (BuildArtifactTraits) StrictValidate(m *BuildArtifactPB) error

func (BuildArtifactTraits) Validate added in v0.3.0

type BuildExport added in v0.3.0

type BuildExport struct {
	// contains filtered or unexported fields
}
var InvalidBuildExport BuildExport

func BuildExportFromProto added in v0.3.0

func BuildExportFromProto(m *BuildExportPB) (BuildExport, error)

func NewBuildExport added in v0.3.0

func NewBuildExport() BuildExport

func (BuildExport) Equal added in v0.3.0

func (o BuildExport) Equal(other interface{ ToProto() M }) bool

func (BuildExport) Hash added in v0.3.0

func (o BuildExport) Hash() string

func (BuildExport) IsValid added in v0.3.0

func (o BuildExport) IsValid() bool

func (BuildExport) MarshalJSON added in v0.3.0

func (o BuildExport) MarshalJSON() ([]byte, error)

func (BuildExport) Message added in v0.3.0

func (o BuildExport) Message() proto.Message

func (BuildExport) Strict added in v0.3.0

func (o BuildExport) Strict() error

func (BuildExport) String added in v0.3.0

func (o BuildExport) String() string

func (BuildExport) ToProto added in v0.3.0

func (o BuildExport) ToProto() M

func (*BuildExport) UnmarshalJSON added in v0.3.0

func (o *BuildExport) UnmarshalJSON(b []byte) (err error)

func (BuildExport) WithLocation added in v0.3.0

func (r BuildExport) WithLocation(loc CodeLocation) BuildExport

func (BuildExport) WithSymbol added in v0.3.0

func (r BuildExport) WithSymbol(sym Symbol) BuildExport

type BuildExportPB added in v0.3.0

type BuildExportPB = runtimesv1.Export

type BuildExportTraits added in v0.3.0

type BuildExportTraits struct{}

func (BuildExportTraits) StrictValidate added in v0.3.0

func (BuildExportTraits) StrictValidate(m *BuildExportPB) error

func (BuildExportTraits) Validate added in v0.3.0

func (BuildExportTraits) Validate(m *BuildExportPB) error

type BuildID

type BuildID = id[buildIDTraits]
var InvalidBuildID BuildID

func NewBuildID

func NewBuildID() BuildID

func ParseBuildID

func ParseBuildID(s string) (BuildID, error)

func StrictParseBuildID

func StrictParseBuildID(s string) (BuildID, error)

type BuildPB

type BuildPB = buildsv1.Build

type BuildRequirement added in v0.3.0

type BuildRequirement struct {
	// contains filtered or unexported fields
}
var InvalidBuildRequirement BuildRequirement

func BuildRequirementFromProto added in v0.3.0

func BuildRequirementFromProto(m *BuildRequirementPB) (BuildRequirement, error)

func NewBuildRequirement added in v0.3.0

func NewBuildRequirement() BuildRequirement

func (BuildRequirement) Equal added in v0.3.0

func (o BuildRequirement) Equal(other interface{ ToProto() M }) bool

func (BuildRequirement) Hash added in v0.3.0

func (o BuildRequirement) Hash() string

func (BuildRequirement) IsValid added in v0.3.0

func (o BuildRequirement) IsValid() bool

func (BuildRequirement) MarshalJSON added in v0.3.0

func (o BuildRequirement) MarshalJSON() ([]byte, error)

func (BuildRequirement) Message added in v0.3.0

func (o BuildRequirement) Message() proto.Message

func (BuildRequirement) Strict added in v0.3.0

func (o BuildRequirement) Strict() error

func (BuildRequirement) String added in v0.3.0

func (o BuildRequirement) String() string

func (BuildRequirement) ToProto added in v0.3.0

func (o BuildRequirement) ToProto() M

func (BuildRequirement) URL added in v0.3.0

func (r BuildRequirement) URL() *url.URL

func (*BuildRequirement) UnmarshalJSON added in v0.3.0

func (o *BuildRequirement) UnmarshalJSON(b []byte) (err error)

func (BuildRequirement) WithLocation added in v0.3.0

func (r BuildRequirement) WithLocation(loc CodeLocation) BuildRequirement

func (BuildRequirement) WithSymbol added in v0.3.0

func (r BuildRequirement) WithSymbol(sym Symbol) BuildRequirement

func (BuildRequirement) WithURL added in v0.3.0

func (r BuildRequirement) WithURL(url *url.URL) BuildRequirement

type BuildRequirementPB added in v0.3.0

type BuildRequirementPB = runtimesv1.Requirement

type BuildRequirementTraits added in v0.3.0

type BuildRequirementTraits struct{}

func (BuildRequirementTraits) StrictValidate added in v0.3.0

func (BuildRequirementTraits) StrictValidate(m *BuildRequirementPB) error

func (BuildRequirementTraits) Validate added in v0.3.0

type BuildTraits added in v0.3.0

type BuildTraits struct{}

func (BuildTraits) StrictValidate added in v0.3.0

func (BuildTraits) StrictValidate(m *BuildPB) error

func (BuildTraits) Validate added in v0.3.0

func (BuildTraits) Validate(m *BuildPB) error

type BytesValue

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

func (BytesValue) Equal added in v0.3.0

func (o BytesValue) Equal(other interface{ ToProto() M }) bool

func (BytesValue) Hash added in v0.3.0

func (o BytesValue) Hash() string

func (BytesValue) IsValid added in v0.3.0

func (o BytesValue) IsValid() bool

func (BytesValue) MarshalJSON added in v0.3.0

func (o BytesValue) MarshalJSON() ([]byte, error)

func (BytesValue) Message added in v0.3.0

func (o BytesValue) Message() proto.Message

func (BytesValue) Strict added in v0.3.0

func (o BytesValue) Strict() error

func (BytesValue) String added in v0.3.0

func (o BytesValue) String() string

func (BytesValue) ToProto added in v0.3.0

func (o BytesValue) ToProto() M

func (*BytesValue) UnmarshalJSON added in v0.3.0

func (o *BytesValue) UnmarshalJSON(b []byte) (err error)

func (BytesValue) Value added in v0.3.0

func (s BytesValue) Value() []byte

type BytesValuePB added in v0.3.0

type BytesValuePB = valuev1.Bytes

type CallFrame

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

func CallFrameFromProto

func CallFrameFromProto(m *CallFramePB) (CallFrame, error)

func (CallFrame) Equal added in v0.3.0

func (o CallFrame) Equal(other interface{ ToProto() M }) bool

func (CallFrame) Hash added in v0.3.0

func (o CallFrame) Hash() string

func (CallFrame) IsValid added in v0.3.0

func (o CallFrame) IsValid() bool

func (CallFrame) Location added in v0.3.0

func (f CallFrame) Location() CodeLocation

func (CallFrame) MarshalJSON added in v0.3.0

func (o CallFrame) MarshalJSON() ([]byte, error)

func (CallFrame) Message added in v0.3.0

func (o CallFrame) Message() proto.Message

func (CallFrame) Name added in v0.3.0

func (f CallFrame) Name() string

func (CallFrame) Strict added in v0.3.0

func (o CallFrame) Strict() error

func (CallFrame) String added in v0.3.0

func (o CallFrame) String() string

func (CallFrame) ToProto added in v0.3.0

func (o CallFrame) ToProto() M

func (*CallFrame) UnmarshalJSON added in v0.3.0

func (o *CallFrame) UnmarshalJSON(b []byte) (err error)

type CallFramePB

type CallFramePB = programv1.CallFrame

type CallFrameTraits added in v0.3.0

type CallFrameTraits struct{}

func (CallFrameTraits) StrictValidate added in v0.3.0

func (CallFrameTraits) StrictValidate(m *CallFramePB) error

func (CallFrameTraits) Validate added in v0.3.0

func (CallFrameTraits) Validate(m *CallFramePB) error

type CodeLocation

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

func CodeLocationFromProto

func CodeLocationFromProto(m *CodeLocationPB) (CodeLocation, error)

func ParseCodeLocation

func ParseCodeLocation(s string) (CodeLocation, error)

func StrictParseCodeLocation

func StrictParseCodeLocation(s string) (CodeLocation, error)

func (CodeLocation) CanonicalString added in v0.3.0

func (l CodeLocation) CanonicalString() string

func (CodeLocation) Col added in v0.3.0

func (l CodeLocation) Col() uint32

func (CodeLocation) Equal added in v0.3.0

func (o CodeLocation) Equal(other interface{ ToProto() M }) bool

func (CodeLocation) Hash added in v0.3.0

func (o CodeLocation) Hash() string

func (CodeLocation) IsValid added in v0.3.0

func (o CodeLocation) IsValid() bool

func (CodeLocation) MarshalJSON added in v0.3.0

func (o CodeLocation) MarshalJSON() ([]byte, error)

func (CodeLocation) Message added in v0.3.0

func (o CodeLocation) Message() proto.Message

func (CodeLocation) Name added in v0.3.0

func (l CodeLocation) Name() string

func (CodeLocation) Path added in v0.3.0

func (l CodeLocation) Path() string

func (CodeLocation) Row added in v0.3.0

func (l CodeLocation) Row() uint32

func (CodeLocation) Strict added in v0.3.0

func (o CodeLocation) Strict() error

func (CodeLocation) String added in v0.3.0

func (o CodeLocation) String() string

func (CodeLocation) ToProto added in v0.3.0

func (o CodeLocation) ToProto() M

func (*CodeLocation) UnmarshalJSON added in v0.3.0

func (o *CodeLocation) UnmarshalJSON(b []byte) (err error)

type CodeLocationPB

type CodeLocationPB = programv1.CodeLocation

type CodeLocationTraits added in v0.3.0

type CodeLocationTraits struct{}

func (CodeLocationTraits) StrictValidate added in v0.3.0

func (t CodeLocationTraits) StrictValidate(m *CodeLocationPB) error

func (CodeLocationTraits) Validate added in v0.3.0

type Connection

type Connection struct {
	// contains filtered or unexported fields
}
var InvalidConnection Connection

func ConnectionFromProto

func ConnectionFromProto(m *ConnectionPB) (Connection, error)

func NewConnection added in v0.3.0

func NewConnection(id ConnectionID) Connection

func StrictConnectionFromProto

func StrictConnectionFromProto(m *ConnectionPB) (Connection, error)
func (p Connection) AddLink(name, value string) Connection

func (Connection) Capabilities added in v0.5.13

func (p Connection) Capabilities() ConnectionCapabilities

func (Connection) Equal added in v0.3.0

func (o Connection) Equal(other interface{ ToProto() M }) bool

func (Connection) Hash added in v0.3.0

func (o Connection) Hash() string

func (Connection) ID added in v0.3.0

func (p Connection) ID() ConnectionID

func (Connection) IntegrationID added in v0.3.0

func (p Connection) IntegrationID() IntegrationID

func (Connection) IsValid added in v0.3.0

func (o Connection) IsValid() bool
func (p Connection) Links() Links

func (Connection) MarshalJSON added in v0.3.0

func (o Connection) MarshalJSON() ([]byte, error)

func (Connection) Message added in v0.3.0

func (o Connection) Message() proto.Message

func (Connection) Name added in v0.3.0

func (p Connection) Name() Symbol

func (Connection) ProjectID added in v0.3.0

func (p Connection) ProjectID() ProjectID

func (Connection) Status added in v0.5.13

func (p Connection) Status() Status

func (Connection) Strict added in v0.3.0

func (o Connection) Strict() error

func (Connection) String added in v0.3.0

func (o Connection) String() string

func (Connection) ToProto added in v0.3.0

func (o Connection) ToProto() M

func (*Connection) UnmarshalJSON added in v0.3.0

func (o *Connection) UnmarshalJSON(b []byte) (err error)

func (Connection) WithCapabilities added in v0.5.13

func (p Connection) WithCapabilities(c ConnectionCapabilities) Connection

func (Connection) WithID added in v0.3.0

func (p Connection) WithID(id ConnectionID) Connection

func (Connection) WithIntegrationID added in v0.3.0

func (p Connection) WithIntegrationID(id IntegrationID) Connection
func (p Connection) WithLinks(links Links) Connection

func (Connection) WithName added in v0.3.0

func (p Connection) WithName(name Symbol) Connection

func (Connection) WithNewID added in v0.3.0

func (p Connection) WithNewID() Connection

func (Connection) WithProjectID added in v0.3.0

func (p Connection) WithProjectID(id ProjectID) Connection

func (Connection) WithStatus added in v0.5.13

func (p Connection) WithStatus(status Status) Connection

func (Connection) WithoutGeneratedFields added in v0.5.13

func (p Connection) WithoutGeneratedFields() Connection

type ConnectionCapabilities added in v0.5.13

type ConnectionCapabilities struct {
	// contains filtered or unexported fields
}
var InvalidConnectionCapabilities ConnectionCapabilities

func ConnectionCapabilitiesFromProto added in v0.5.13

func ConnectionCapabilitiesFromProto(m *ConnectionCapabilitiesPB) (ConnectionCapabilities, error)

func (ConnectionCapabilities) Equal added in v0.5.13

func (o ConnectionCapabilities) Equal(other interface{ ToProto() M }) bool

func (ConnectionCapabilities) Hash added in v0.5.13

func (o ConnectionCapabilities) Hash() string

func (ConnectionCapabilities) IsValid added in v0.5.13

func (o ConnectionCapabilities) IsValid() bool

func (ConnectionCapabilities) MarshalJSON added in v0.5.13

func (o ConnectionCapabilities) MarshalJSON() ([]byte, error)

func (ConnectionCapabilities) Message added in v0.5.13

func (o ConnectionCapabilities) Message() proto.Message

func (ConnectionCapabilities) RequiresConnectionInit added in v0.5.13

func (p ConnectionCapabilities) RequiresConnectionInit() bool

func (ConnectionCapabilities) Strict added in v0.5.13

func (o ConnectionCapabilities) Strict() error

func (ConnectionCapabilities) String added in v0.5.13

func (o ConnectionCapabilities) String() string

func (ConnectionCapabilities) SupportsConnectionInit added in v0.5.13

func (p ConnectionCapabilities) SupportsConnectionInit() bool

func (ConnectionCapabilities) SupportsConnectionTest added in v0.5.13

func (p ConnectionCapabilities) SupportsConnectionTest() bool

func (ConnectionCapabilities) ToProto added in v0.5.13

func (o ConnectionCapabilities) ToProto() M

func (*ConnectionCapabilities) UnmarshalJSON added in v0.5.13

func (o *ConnectionCapabilities) UnmarshalJSON(b []byte) (err error)

func (ConnectionCapabilities) WithRequiresConnectionInit added in v0.5.13

func (p ConnectionCapabilities) WithRequiresConnectionInit(v bool) ConnectionCapabilities

func (ConnectionCapabilities) WithSupportsConnectionInit added in v0.5.13

func (p ConnectionCapabilities) WithSupportsConnectionInit(v bool) ConnectionCapabilities

func (ConnectionCapabilities) WithSupportsConnectionTest added in v0.5.13

func (p ConnectionCapabilities) WithSupportsConnectionTest(v bool) ConnectionCapabilities

type ConnectionCapabilitiesPB added in v0.5.13

type ConnectionCapabilitiesPB = connectionsv1.Capabilities

type ConnectionCapabilitiesTraits added in v0.5.13

type ConnectionCapabilitiesTraits struct{}

func (ConnectionCapabilitiesTraits) StrictValidate added in v0.5.13

func (ConnectionCapabilitiesTraits) Validate added in v0.5.13

type ConnectionID

type ConnectionID = id[connectionIDTraits]
var InvalidConnectionID ConnectionID

func NewConnectionID

func NewConnectionID() ConnectionID

func ParseConnectionID

func ParseConnectionID(s string) (ConnectionID, error)

func StrictParseConnectionID

func StrictParseConnectionID(s string) (ConnectionID, error)

type ConnectionPB

type ConnectionPB = connectionv1.Connection

type ConnectionTraits added in v0.3.0

type ConnectionTraits struct{}

func (ConnectionTraits) StrictValidate added in v0.3.0

func (ConnectionTraits) StrictValidate(m *ConnectionPB) error

func (ConnectionTraits) Validate added in v0.3.0

func (ConnectionTraits) Validate(m *ConnectionPB) error

type Deployment

type Deployment struct {
	// contains filtered or unexported fields
}
var InvalidDeployment Deployment

func DeploymentFromProto

func DeploymentFromProto(m *DeploymentPB) (Deployment, error)

func StrictDeploymentFromProto

func StrictDeploymentFromProto(m *DeploymentPB) (Deployment, error)

func (Deployment) BuildID added in v0.3.0

func (p Deployment) BuildID() BuildID

func (Deployment) EnvID added in v0.3.0

func (p Deployment) EnvID() EnvID

func (Deployment) Equal added in v0.3.0

func (o Deployment) Equal(other interface{ ToProto() M }) bool

func (Deployment) Hash added in v0.3.0

func (o Deployment) Hash() string

func (Deployment) ID added in v0.3.0

func (p Deployment) ID() DeploymentID

func (Deployment) IsValid added in v0.3.0

func (o Deployment) IsValid() bool

func (Deployment) MarshalJSON added in v0.3.0

func (o Deployment) MarshalJSON() ([]byte, error)

func (Deployment) Message added in v0.3.0

func (o Deployment) Message() proto.Message

func (Deployment) State added in v0.3.0

func (p Deployment) State() DeploymentState

func (Deployment) Strict added in v0.3.0

func (o Deployment) Strict() error

func (Deployment) String added in v0.3.0

func (o Deployment) String() string

func (Deployment) ToProto added in v0.3.0

func (o Deployment) ToProto() M

func (*Deployment) UnmarshalJSON added in v0.3.0

func (o *Deployment) UnmarshalJSON(b []byte) (err error)

func (Deployment) WithNewID added in v0.3.0

func (p Deployment) WithNewID() Deployment

func (Deployment) WithState added in v0.3.0

func (p Deployment) WithState(s DeploymentState) Deployment

func (Deployment) WithoutTimestamps added in v0.3.0

func (p Deployment) WithoutTimestamps() Deployment

type DeploymentID

type DeploymentID = id[deploymentIDTraits]
var InvalidDeploymentID DeploymentID

func NewDeploymentID

func NewDeploymentID() DeploymentID

func ParseDeploymentID

func ParseDeploymentID(s string) (DeploymentID, error)

type DeploymentPB

type DeploymentPB = deploymentv1.Deployment

type DeploymentState

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

func ParseDeploymentState

func ParseDeploymentState(raw string) (DeploymentState, error)

func (DeploymentState) IsZero added in v0.3.0

func (e DeploymentState) IsZero() bool

func (DeploymentState) MarshalJSON added in v0.3.0

func (e DeploymentState) MarshalJSON() ([]byte, error)

func (DeploymentState) Prefix added in v0.3.0

func (e DeploymentState) Prefix() string

func (DeploymentState) Strict added in v0.3.0

func (e DeploymentState) Strict() error

func (DeploymentState) String

func (e DeploymentState) String() string

func (DeploymentState) ToProto

func (e DeploymentState) ToProto() E

func (*DeploymentState) UnmarshalJSON added in v0.3.0

func (e *DeploymentState) UnmarshalJSON(b []byte) (err error)

type DeploymentTraits added in v0.3.0

type DeploymentTraits struct{}

func (DeploymentTraits) StrictValidate added in v0.3.0

func (DeploymentTraits) StrictValidate(m *DeploymentPB) error

func (DeploymentTraits) Validate added in v0.3.0

func (DeploymentTraits) Validate(m *DeploymentPB) error

type DictItem added in v0.3.0

type DictItem struct{ K, V Value }

type DictValue

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

func (DictValue) Equal added in v0.3.0

func (o DictValue) Equal(other interface{ ToProto() M }) bool

func (DictValue) Hash added in v0.3.0

func (o DictValue) Hash() string

func (DictValue) IsValid added in v0.3.0

func (o DictValue) IsValid() bool

func (DictValue) Items added in v0.3.0

func (d DictValue) Items() []DictItem

func (DictValue) MarshalJSON added in v0.3.0

func (o DictValue) MarshalJSON() ([]byte, error)

func (DictValue) Message added in v0.3.0

func (o DictValue) Message() proto.Message

func (DictValue) Strict added in v0.3.0

func (o DictValue) Strict() error

func (DictValue) String added in v0.3.0

func (o DictValue) String() string

func (DictValue) ToProto added in v0.3.0

func (o DictValue) ToProto() M

func (DictValue) ToStringValuesMap added in v0.3.0

func (d DictValue) ToStringValuesMap() (map[string]Value, error)

func (*DictValue) UnmarshalJSON added in v0.3.0

func (o *DictValue) UnmarshalJSON(b []byte) (err error)

type DictValuePB added in v0.3.0

type DictValuePB = valuev1.Dict

type DurationValue

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

func (DurationValue) Equal added in v0.3.0

func (o DurationValue) Equal(other interface{ ToProto() M }) bool

func (DurationValue) Hash added in v0.3.0

func (o DurationValue) Hash() string

func (DurationValue) IsValid added in v0.3.0

func (o DurationValue) IsValid() bool

func (DurationValue) MarshalJSON added in v0.3.0

func (o DurationValue) MarshalJSON() ([]byte, error)

func (DurationValue) Message added in v0.3.0

func (o DurationValue) Message() proto.Message

func (DurationValue) Strict added in v0.3.0

func (o DurationValue) Strict() error

func (DurationValue) String added in v0.3.0

func (o DurationValue) String() string

func (DurationValue) ToProto added in v0.3.0

func (o DurationValue) ToProto() M

func (*DurationValue) UnmarshalJSON added in v0.3.0

func (o *DurationValue) UnmarshalJSON(b []byte) (err error)

func (DurationValue) Value added in v0.3.0

func (s DurationValue) Value() time.Duration

type DurationValuePB added in v0.3.0

type DurationValuePB = valuev1.Duration

type Env

type Env struct {
	// contains filtered or unexported fields
}
var InvalidEnv Env

func EnvFromProto

func EnvFromProto(m *EnvPB) (Env, error)

func NewEnv added in v0.3.0

func NewEnv() Env

func StrictEnvFromProto

func StrictEnvFromProto(m *EnvPB) (Env, error)

func (Env) Equal added in v0.3.0

func (o Env) Equal(other interface{ ToProto() M }) bool

func (Env) Hash added in v0.3.0

func (o Env) Hash() string

func (Env) ID added in v0.3.0

func (p Env) ID() EnvID

func (Env) IsValid added in v0.3.0

func (o Env) IsValid() bool

func (Env) MarshalJSON added in v0.3.0

func (o Env) MarshalJSON() ([]byte, error)

func (Env) Message added in v0.3.0

func (o Env) Message() proto.Message

func (Env) Name added in v0.3.0

func (p Env) Name() Symbol

func (Env) ProjectID added in v0.3.0

func (p Env) ProjectID() ProjectID

func (Env) Strict added in v0.3.0

func (o Env) Strict() error

func (Env) String added in v0.3.0

func (o Env) String() string

func (Env) ToProto added in v0.3.0

func (o Env) ToProto() M

func (*Env) UnmarshalJSON added in v0.3.0

func (o *Env) UnmarshalJSON(b []byte) (err error)

func (Env) WithID added in v0.3.0

func (p Env) WithID(id EnvID) Env

func (Env) WithName added in v0.3.0

func (p Env) WithName(name Symbol) Env

func (Env) WithNewID added in v0.3.0

func (p Env) WithNewID() Env

func (Env) WithProjectID added in v0.3.0

func (p Env) WithProjectID(id ProjectID) Env

type EnvID

type EnvID = id[envIDTraits]
var InvalidEnvID EnvID

func NewEnvID

func NewEnvID() EnvID

func ParseEnvID

func ParseEnvID(s string) (EnvID, error)

func StrictParseEnvID

func StrictParseEnvID(s string) (EnvID, error)

type EnvPB

type EnvPB = envv1.Env

type EnvTraits added in v0.3.0

type EnvTraits struct{}

func (EnvTraits) StrictValidate added in v0.3.0

func (EnvTraits) StrictValidate(m *EnvPB) error

func (EnvTraits) Validate added in v0.3.0

func (EnvTraits) Validate(m *EnvPB) error

type Event

type Event struct {
	// contains filtered or unexported fields
}
var InvalidEvent Event

func EventFromProto

func EventFromProto(m *EventPB) (Event, error)

func StrictEventFromProto

func StrictEventFromProto(m *EventPB) (Event, error)

func (Event) ConnectionID added in v0.5.0

func (e Event) ConnectionID() ConnectionID

func (Event) CreatedAt added in v0.3.0

func (e Event) CreatedAt() time.Time

func (Event) Data added in v0.3.0

func (e Event) Data() map[string]Value

func (Event) Equal added in v0.3.0

func (o Event) Equal(other interface{ ToProto() M }) bool

func (Event) Hash added in v0.3.0

func (o Event) Hash() string

func (Event) ID added in v0.3.0

func (p Event) ID() EventID

func (Event) IsValid added in v0.3.0

func (o Event) IsValid() bool

func (Event) MarshalJSON added in v0.3.0

func (o Event) MarshalJSON() ([]byte, error)

func (Event) Matches added in v0.4.0

func (e Event) Matches(expr string) (bool, error)

func (Event) Memo added in v0.3.0

func (e Event) Memo() map[string]string

func (Event) Message added in v0.3.0

func (o Event) Message() proto.Message

func (Event) Seq added in v0.3.0

func (e Event) Seq() uint64

func (Event) Strict added in v0.3.0

func (o Event) Strict() error

func (Event) String added in v0.3.0

func (o Event) String() string

func (Event) ToProto added in v0.3.0

func (o Event) ToProto() M

func (Event) ToValues added in v0.3.0

func (e Event) ToValues() map[string]Value

func (Event) Type added in v0.3.0

func (e Event) Type() string

func (*Event) UnmarshalJSON added in v0.3.0

func (o *Event) UnmarshalJSON(b []byte) (err error)

func (Event) WithConnectionID added in v0.5.0

func (e Event) WithConnectionID(cid ConnectionID) Event

func (Event) WithCreatedAt added in v0.3.0

func (e Event) WithCreatedAt(t time.Time) Event

func (Event) WithData added in v0.6.0

func (e Event) WithData(data map[string]Value) Event

func (Event) WithMemo added in v0.3.0

func (e Event) WithMemo(memo map[string]string) Event

func (Event) WithNewID added in v0.3.0

func (e Event) WithNewID() Event

type EventID

type EventID = id[eventIDTraits]
var InvalidEventID EventID

func NewEventID

func NewEventID() EventID

func ParseEventID

func ParseEventID(s string) (EventID, error)

type EventPB

type EventPB = eventv1.Event

type EventRecord

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

func EventRecordFromProto

func EventRecordFromProto(m *EventRecordPB) (EventRecord, error)

func NewEventRecord added in v0.3.0

func NewEventRecord(eventID EventID, state EventState) EventRecord

func StrictEventRecordFromProto

func StrictEventRecordFromProto(m *EventRecordPB) (EventRecord, error)

func (EventRecord) Equal added in v0.3.0

func (o EventRecord) Equal(other interface{ ToProto() M }) bool

func (EventRecord) EventID added in v0.3.0

func (p EventRecord) EventID() (_ EventID)

func (EventRecord) Hash added in v0.3.0

func (o EventRecord) Hash() string

func (EventRecord) IsValid added in v0.3.0

func (o EventRecord) IsValid() bool

func (EventRecord) MarshalJSON added in v0.3.0

func (o EventRecord) MarshalJSON() ([]byte, error)

func (EventRecord) Message added in v0.3.0

func (o EventRecord) Message() proto.Message

func (EventRecord) Seq added in v0.3.0

func (p EventRecord) Seq() uint32

func (EventRecord) State added in v0.3.0

func (p EventRecord) State() EventState

func (EventRecord) Strict added in v0.3.0

func (o EventRecord) Strict() error

func (EventRecord) String added in v0.3.0

func (o EventRecord) String() string

func (EventRecord) ToProto added in v0.3.0

func (o EventRecord) ToProto() M

func (*EventRecord) UnmarshalJSON added in v0.3.0

func (o *EventRecord) UnmarshalJSON(b []byte) (err error)

func (EventRecord) WithCreatedAt added in v0.3.0

func (p EventRecord) WithCreatedAt(createdAt time.Time) EventRecord

func (EventRecord) WithSeq added in v0.3.0

func (p EventRecord) WithSeq(seq uint32) EventRecord

type EventRecordPB

type EventRecordPB = eventv1.EventRecord

type EventRecordTraits added in v0.3.0

type EventRecordTraits struct{}

func (EventRecordTraits) StrictValidate added in v0.3.0

func (t EventRecordTraits) StrictValidate(m *EventRecordPB) error

func (EventRecordTraits) Validate added in v0.3.0

func (EventRecordTraits) Validate(m *EventRecordPB) error

type EventState

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

func EventStateFromProto added in v0.3.0

func EventStateFromProto(e eventsv1.EventState) (EventState, error)

func ParseEventState added in v0.3.0

func ParseEventState(raw string) (EventState, error)

func (EventState) IsZero added in v0.3.0

func (e EventState) IsZero() bool

func (EventState) MarshalJSON added in v0.3.0

func (e EventState) MarshalJSON() ([]byte, error)

func (EventState) Prefix added in v0.3.0

func (e EventState) Prefix() string

func (EventState) Strict added in v0.3.0

func (e EventState) Strict() error

func (EventState) String

func (e EventState) String() string

func (EventState) ToProto

func (e EventState) ToProto() E

func (*EventState) UnmarshalJSON added in v0.3.0

func (e *EventState) UnmarshalJSON(b []byte) (err error)

type EventTraits added in v0.3.0

type EventTraits struct{}

func (EventTraits) StrictValidate added in v0.3.0

func (EventTraits) StrictValidate(m *EventPB) error

func (EventTraits) Validate added in v0.3.0

func (EventTraits) Validate(m *EventPB) error

type ExecutorID

type ExecutorID struct {
	// contains filtered or unexported fields
}
var InvalidExecutorID ExecutorID

func NewExecutorID

func NewExecutorID[T concreteExecutorID](in T) ExecutorID

func ParseExecutorID

func ParseExecutorID(s string) (ExecutorID, error)

func (ExecutorID) Hash added in v0.3.0

func (i ExecutorID) Hash() string

func (ExecutorID) IsIntegrationID added in v0.3.0

func (e ExecutorID) IsIntegrationID() bool

func (ExecutorID) IsRunID added in v0.3.0

func (e ExecutorID) IsRunID() bool

func (ExecutorID) IsValid added in v0.3.0

func (i ExecutorID) IsValid() bool

func (ExecutorID) Kind added in v0.3.0

func (i ExecutorID) Kind() string

func (ExecutorID) MarshalJSON added in v0.3.0

func (i ExecutorID) MarshalJSON() ([]byte, error)

func (ExecutorID) Strict added in v0.3.0

func (i ExecutorID) Strict() error

func (ExecutorID) String added in v0.3.0

func (i ExecutorID) String() string

func (ExecutorID) ToIntegrationID added in v0.3.0

func (e ExecutorID) ToIntegrationID() IntegrationID

func (ExecutorID) ToRunID added in v0.3.0

func (e ExecutorID) ToRunID() RunID

func (ExecutorID) UUIDValue added in v0.4.6

func (i ExecutorID) UUIDValue() UUID

func (*ExecutorID) UnmarshalJSON added in v0.3.0

func (i *ExecutorID) UnmarshalJSON(data []byte) (err error)

func (ExecutorID) Value added in v0.3.0

func (i ExecutorID) Value() *UUID

type FloatValue

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

func (FloatValue) Equal added in v0.3.0

func (o FloatValue) Equal(other interface{ ToProto() M }) bool

func (FloatValue) Hash added in v0.3.0

func (o FloatValue) Hash() string

func (FloatValue) IsValid added in v0.3.0

func (o FloatValue) IsValid() bool

func (FloatValue) MarshalJSON added in v0.3.0

func (o FloatValue) MarshalJSON() ([]byte, error)

func (FloatValue) Message added in v0.3.0

func (o FloatValue) Message() proto.Message

func (FloatValue) Strict added in v0.3.0

func (o FloatValue) Strict() error

func (FloatValue) String added in v0.3.0

func (o FloatValue) String() string

func (FloatValue) ToProto added in v0.3.0

func (o FloatValue) ToProto() M

func (*FloatValue) UnmarshalJSON added in v0.3.0

func (o *FloatValue) UnmarshalJSON(b []byte) (err error)

func (FloatValue) Value added in v0.3.0

func (s FloatValue) Value() float64

type FloatValuePB added in v0.3.0

type FloatValuePB = valuev1.Float

type FunctionFlag

type FunctionFlag string
const (
	PrivilidgedFunctionFlag    FunctionFlag = "privilidged" // pass workflow context.
	PureFunctionFlag           FunctionFlag = "pure"        // do not run in an activity.
	DisablePollingFunctionFlag FunctionFlag = "no-poll"     // do not poll.
	ConstFunctionFlag          FunctionFlag = "const"       // result is serialized in data.
)

func (FunctionFlag) String

func (ff FunctionFlag) String() string

type FunctionValue

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

func (FunctionValue) ArgNames added in v0.3.0

func (f FunctionValue) ArgNames() []string

func (FunctionValue) ConstValue added in v0.4.0

func (f FunctionValue) ConstValue() (Value, error)

func (FunctionValue) Data added in v0.3.0

func (f FunctionValue) Data() []byte

func (FunctionValue) Equal added in v0.3.0

func (o FunctionValue) Equal(other interface{ ToProto() M }) bool

func (FunctionValue) ExecutorID added in v0.3.0

func (f FunctionValue) ExecutorID() ExecutorID

func (FunctionValue) HasFlag added in v0.3.0

func (f FunctionValue) HasFlag(flag FunctionFlag) bool

func (FunctionValue) Hash added in v0.3.0

func (o FunctionValue) Hash() string

func (FunctionValue) IsValid added in v0.3.0

func (o FunctionValue) IsValid() bool

func (FunctionValue) MarshalJSON added in v0.3.0

func (o FunctionValue) MarshalJSON() ([]byte, error)

func (FunctionValue) Message added in v0.3.0

func (o FunctionValue) Message() proto.Message

func (FunctionValue) Name added in v0.3.0

func (f FunctionValue) Name() Symbol

func (FunctionValue) Strict added in v0.3.0

func (o FunctionValue) Strict() error

func (FunctionValue) String added in v0.3.0

func (o FunctionValue) String() string

func (FunctionValue) ToProto added in v0.3.0

func (o FunctionValue) ToProto() M

func (FunctionValue) UniqueID added in v0.3.0

func (f FunctionValue) UniqueID() string

func (*FunctionValue) UnmarshalJSON added in v0.3.0

func (o *FunctionValue) UnmarshalJSON(b []byte) (err error)

type FunctionValuePB added in v0.3.0

type FunctionValuePB = valuev1.Function

type ID

type ID interface {
	json.Marshaler
	fmt.Stringer

	// Kind returns the type kind, which is the id prefix.
	Kind() string

	// Value returns the id value, meaning without the prefix.
	Value() *UUID

	UUIDValue() UUID
	// contains filtered or unexported methods
}

type IntegerValue

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

func (IntegerValue) Equal added in v0.3.0

func (o IntegerValue) Equal(other interface{ ToProto() M }) bool

func (IntegerValue) Hash added in v0.3.0

func (o IntegerValue) Hash() string

func (IntegerValue) IsValid added in v0.3.0

func (o IntegerValue) IsValid() bool

func (IntegerValue) MarshalJSON added in v0.3.0

func (o IntegerValue) MarshalJSON() ([]byte, error)

func (IntegerValue) Message added in v0.3.0

func (o IntegerValue) Message() proto.Message

func (IntegerValue) Strict added in v0.3.0

func (o IntegerValue) Strict() error

func (IntegerValue) String added in v0.3.0

func (o IntegerValue) String() string

func (IntegerValue) ToProto added in v0.3.0

func (o IntegerValue) ToProto() M

func (*IntegerValue) UnmarshalJSON added in v0.3.0

func (o *IntegerValue) UnmarshalJSON(b []byte) (err error)

func (IntegerValue) Value added in v0.3.0

func (s IntegerValue) Value() int64

type IntegerValuePB added in v0.3.0

type IntegerValuePB = valuev1.Integer

type Integration

type Integration struct {
	// contains filtered or unexported fields
}
var InvalidIntegration Integration

func IntegrationFromProto

func IntegrationFromProto(m *IntegrationPB) (Integration, error)

func StrictIntegrationFromProto

func StrictIntegrationFromProto(m *IntegrationPB) (Integration, error)

func (Integration) ConnectionCapabilities added in v0.5.13

func (p Integration) ConnectionCapabilities() ConnectionCapabilities

func (Integration) ConnectionURL added in v0.3.0

func (p Integration) ConnectionURL() *url.URL

func (Integration) Description added in v0.3.0

func (p Integration) Description() string

func (Integration) DisplayName added in v0.3.0

func (p Integration) DisplayName() string

func (Integration) Equal added in v0.3.0

func (o Integration) Equal(other interface{ ToProto() M }) bool

func (Integration) Hash added in v0.3.0

func (o Integration) Hash() string

func (Integration) ID added in v0.3.0

func (p Integration) ID() IntegrationID

func (Integration) InitialConnectionStatus added in v0.5.13

func (p Integration) InitialConnectionStatus() Status

func (Integration) IsValid added in v0.3.0

func (o Integration) IsValid() bool

func (Integration) LogoURL added in v0.3.0

func (p Integration) LogoURL() *url.URL

func (Integration) MarshalJSON added in v0.3.0

func (o Integration) MarshalJSON() ([]byte, error)

func (Integration) Message added in v0.3.0

func (o Integration) Message() proto.Message

func (Integration) Strict added in v0.3.0

func (o Integration) Strict() error

func (Integration) String added in v0.3.0

func (o Integration) String() string

func (Integration) ToProto added in v0.3.0

func (o Integration) ToProto() M

func (Integration) UniqueName added in v0.3.0

func (p Integration) UniqueName() Symbol

func (*Integration) UnmarshalJSON added in v0.3.0

func (o *Integration) UnmarshalJSON(b []byte) (err error)

func (Integration) UpdateModule added in v0.3.0

func (p Integration) UpdateModule(m Module) Integration
func (p Integration) UserLinks() map[string]string

func (Integration) WithConnectionCapabilities added in v0.5.13

func (p Integration) WithConnectionCapabilities(c ConnectionCapabilities) Integration

func (Integration) WithDescription added in v0.3.0

func (p Integration) WithDescription(s string) Integration

func (Integration) WithInitialConnectionStatus added in v0.5.13

func (p Integration) WithInitialConnectionStatus(s Status) Integration

func (Integration) WithModule added in v0.3.0

func (p Integration) WithModule(m Module) Integration
func (p Integration) WithUserLinks(links map[string]string) Integration

type IntegrationID

type IntegrationID = id[integrationIDTraits]
var InvalidIntegrationID IntegrationID

func NewIntegrationID

func NewIntegrationID() IntegrationID

func NewIntegrationIDFromName added in v0.4.6

func NewIntegrationIDFromName(name string) IntegrationID

func ParseIntegrationID

func ParseIntegrationID(s string) (IntegrationID, error)

func StrictParseIntegrationID

func StrictParseIntegrationID(s string) (IntegrationID, error)

type IntegrationPB

type IntegrationPB = integrationv1.Integration

type IntegrationTraits added in v0.3.0

type IntegrationTraits struct{}

func (IntegrationTraits) StrictValidate added in v0.3.0

func (IntegrationTraits) StrictValidate(m *IntegrationPB) error

func (IntegrationTraits) Validate added in v0.3.0

func (IntegrationTraits) Validate(m *IntegrationPB) error
type Links map[string]string

func (Links) InitURL added in v0.5.13

func (l Links) InitURL() string

type ListValue

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

func (ListValue) Equal added in v0.3.0

func (o ListValue) Equal(other interface{ ToProto() M }) bool

func (ListValue) Hash added in v0.3.0

func (o ListValue) Hash() string

func (ListValue) IsValid added in v0.3.0

func (o ListValue) IsValid() bool

func (ListValue) MarshalJSON added in v0.3.0

func (o ListValue) MarshalJSON() ([]byte, error)

func (ListValue) Message added in v0.3.0

func (o ListValue) Message() proto.Message

func (ListValue) Strict added in v0.3.0

func (o ListValue) Strict() error

func (ListValue) String added in v0.3.0

func (o ListValue) String() string

func (ListValue) ToProto added in v0.3.0

func (o ListValue) ToProto() M

func (*ListValue) UnmarshalJSON added in v0.3.0

func (o *ListValue) UnmarshalJSON(b []byte) (err error)

func (ListValue) Values added in v0.3.0

func (l ListValue) Values() []Value

type ListValuePB added in v0.3.0

type ListValuePB = valuev1.List

type Module

type Module struct {
	// contains filtered or unexported fields
}
var InvalidModule Module

func ModuleFromProto

func ModuleFromProto(m *ModulePB) (Module, error)

func NewModule

func NewModule(fs map[string]ModuleFunction, vs map[string]ModuleVariable) (Module, error)

func StrictModuleFromProto

func StrictModuleFromProto(m *ModulePB) (Module, error)

func (Module) Equal added in v0.3.0

func (o Module) Equal(other interface{ ToProto() M }) bool

func (Module) Hash added in v0.3.0

func (o Module) Hash() string

func (Module) IsValid added in v0.3.0

func (o Module) IsValid() bool

func (Module) MarshalJSON added in v0.3.0

func (o Module) MarshalJSON() ([]byte, error)

func (Module) Message added in v0.3.0

func (o Module) Message() proto.Message

func (Module) Strict added in v0.3.0

func (o Module) Strict() error

func (Module) String added in v0.3.0

func (o Module) String() string

func (Module) ToProto added in v0.3.0

func (o Module) ToProto() M

func (*Module) UnmarshalJSON added in v0.3.0

func (o *Module) UnmarshalJSON(b []byte) (err error)

type ModuleFunction

type ModuleFunction struct {
	// contains filtered or unexported fields
}
var InvalidModuleFunction ModuleFunction

func ModuleFunctionFromProto

func ModuleFunctionFromProto(m *ModuleFunctionPB) (ModuleFunction, error)

func StrictModuleFunctionFromProto

func StrictModuleFunctionFromProto(m *ModuleFunctionPB) (ModuleFunction, error)

func (ModuleFunction) Equal added in v0.3.0

func (o ModuleFunction) Equal(other interface{ ToProto() M }) bool

func (ModuleFunction) Hash added in v0.3.0

func (o ModuleFunction) Hash() string

func (ModuleFunction) IsValid added in v0.3.0

func (o ModuleFunction) IsValid() bool

func (ModuleFunction) MarshalJSON added in v0.3.0

func (o ModuleFunction) MarshalJSON() ([]byte, error)

func (ModuleFunction) Message added in v0.3.0

func (o ModuleFunction) Message() proto.Message

func (ModuleFunction) Strict added in v0.3.0

func (o ModuleFunction) Strict() error

func (ModuleFunction) String added in v0.3.0

func (o ModuleFunction) String() string

func (ModuleFunction) ToProto added in v0.3.0

func (o ModuleFunction) ToProto() M

func (*ModuleFunction) UnmarshalJSON added in v0.3.0

func (o *ModuleFunction) UnmarshalJSON(b []byte) (err error)

type ModuleFunctionField added in v0.3.0

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

func ModuleFunctionFieldFromProto added in v0.3.0

func ModuleFunctionFieldFromProto(m *ModuleFunctionFieldPB) (ModuleFunctionField, error)

func StrictModuleFunctionFieldFromProto added in v0.3.0

func StrictModuleFunctionFieldFromProto(m *ModuleFunctionFieldPB) (ModuleFunctionField, error)

func (ModuleFunctionField) Equal added in v0.3.0

func (o ModuleFunctionField) Equal(other interface{ ToProto() M }) bool

func (ModuleFunctionField) Hash added in v0.3.0

func (o ModuleFunctionField) Hash() string

func (ModuleFunctionField) IsValid added in v0.3.0

func (o ModuleFunctionField) IsValid() bool

func (ModuleFunctionField) MarshalJSON added in v0.3.0

func (o ModuleFunctionField) MarshalJSON() ([]byte, error)

func (ModuleFunctionField) Message added in v0.3.0

func (o ModuleFunctionField) Message() proto.Message

func (ModuleFunctionField) Strict added in v0.3.0

func (o ModuleFunctionField) Strict() error

func (ModuleFunctionField) String added in v0.3.0

func (o ModuleFunctionField) String() string

func (ModuleFunctionField) ToProto added in v0.3.0

func (o ModuleFunctionField) ToProto() M

func (*ModuleFunctionField) UnmarshalJSON added in v0.3.0

func (o *ModuleFunctionField) UnmarshalJSON(b []byte) (err error)

type ModuleFunctionFieldPB

type ModuleFunctionFieldPB = modulev1.FunctionField

type ModuleFunctionFieldTraits added in v0.3.0

type ModuleFunctionFieldTraits struct{}

func (ModuleFunctionFieldTraits) StrictValidate added in v0.3.0

func (ModuleFunctionFieldTraits) Validate added in v0.3.0

type ModuleFunctionPB

type ModuleFunctionPB = modulev1.Function

type ModuleFunctionTraits added in v0.3.0

type ModuleFunctionTraits struct{}

func (ModuleFunctionTraits) StrictValidate added in v0.3.0

func (ModuleFunctionTraits) StrictValidate(m *ModuleFunctionPB) error

func (ModuleFunctionTraits) Validate added in v0.3.0

type ModulePB

type ModulePB = modulev1.Module

type ModuleTraits added in v0.3.0

type ModuleTraits struct{}

func (ModuleTraits) StrictValidate added in v0.3.0

func (ModuleTraits) StrictValidate(m *ModulePB) error

func (ModuleTraits) Validate added in v0.3.0

func (ModuleTraits) Validate(m *ModulePB) error

type ModuleValue

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

func (ModuleValue) Equal added in v0.3.0

func (o ModuleValue) Equal(other interface{ ToProto() M }) bool

func (ModuleValue) Hash added in v0.3.0

func (o ModuleValue) Hash() string

func (ModuleValue) IsValid added in v0.3.0

func (o ModuleValue) IsValid() bool

func (ModuleValue) MarshalJSON added in v0.3.0

func (o ModuleValue) MarshalJSON() ([]byte, error)

func (ModuleValue) Members added in v0.3.0

func (s ModuleValue) Members() map[string]Value

func (ModuleValue) Message added in v0.3.0

func (o ModuleValue) Message() proto.Message

func (ModuleValue) Name added in v0.3.0

func (s ModuleValue) Name() Symbol

func (ModuleValue) Strict added in v0.3.0

func (o ModuleValue) Strict() error

func (ModuleValue) String added in v0.3.0

func (o ModuleValue) String() string

func (ModuleValue) ToProto added in v0.3.0

func (o ModuleValue) ToProto() M

func (*ModuleValue) UnmarshalJSON added in v0.3.0

func (o *ModuleValue) UnmarshalJSON(b []byte) (err error)

type ModuleValuePB added in v0.3.0

type ModuleValuePB = valuev1.Module

type ModuleVariable

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

func ModuleVariableFromProto

func ModuleVariableFromProto(m *ModuleVariablePB) (ModuleVariable, error)

func StrictModuleVariableFromProto

func StrictModuleVariableFromProto(m *ModuleVariablePB) (ModuleVariable, error)

func (ModuleVariable) Equal added in v0.3.0

func (o ModuleVariable) Equal(other interface{ ToProto() M }) bool

func (ModuleVariable) Hash added in v0.3.0

func (o ModuleVariable) Hash() string

func (ModuleVariable) IsValid added in v0.3.0

func (o ModuleVariable) IsValid() bool

func (ModuleVariable) MarshalJSON added in v0.3.0

func (o ModuleVariable) MarshalJSON() ([]byte, error)

func (ModuleVariable) Message added in v0.3.0

func (o ModuleVariable) Message() proto.Message

func (ModuleVariable) Strict added in v0.3.0

func (o ModuleVariable) Strict() error

func (ModuleVariable) String added in v0.3.0

func (o ModuleVariable) String() string

func (ModuleVariable) ToProto added in v0.3.0

func (o ModuleVariable) ToProto() M

func (*ModuleVariable) UnmarshalJSON added in v0.3.0

func (o *ModuleVariable) UnmarshalJSON(b []byte) (err error)

type ModuleVariablePB

type ModuleVariablePB = modulev1.Variable

type ModuleVariableTraits added in v0.3.0

type ModuleVariableTraits struct{}

func (ModuleVariableTraits) StrictValidate added in v0.3.0

func (ModuleVariableTraits) StrictValidate(m *ModuleVariablePB) error

func (ModuleVariableTraits) Validate added in v0.3.0

type NothingValue

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

func (NothingValue) Equal added in v0.3.0

func (o NothingValue) Equal(other interface{ ToProto() M }) bool

func (NothingValue) Hash added in v0.3.0

func (o NothingValue) Hash() string

func (NothingValue) IsValid added in v0.3.0

func (o NothingValue) IsValid() bool

func (NothingValue) MarshalJSON added in v0.3.0

func (o NothingValue) MarshalJSON() ([]byte, error)

func (NothingValue) Message added in v0.3.0

func (o NothingValue) Message() proto.Message

func (NothingValue) Strict added in v0.3.0

func (o NothingValue) Strict() error

func (NothingValue) String added in v0.3.0

func (o NothingValue) String() string

func (NothingValue) ToProto added in v0.3.0

func (o NothingValue) ToProto() M

func (*NothingValue) UnmarshalJSON added in v0.3.0

func (o *NothingValue) UnmarshalJSON(b []byte) (err error)

type NothingValuePB added in v0.3.0

type NothingValuePB = valuev1.Nothing

type Object

type Object interface {
	json.Marshaler
	fmt.Stringer
	// contains filtered or unexported methods
}

type PaginationRequest added in v0.4.6

type PaginationRequest struct {
	PageSize  int32
	Skip      int32
	PageToken string
}

type PaginationResult added in v0.4.6

type PaginationResult struct {
	TotalCount    int64
	NextPageToken string
}

type ProgramError

type ProgramError struct {
	// contains filtered or unexported fields
}
var InvalidProgramError ProgramError

func FromError added in v0.3.0

func FromError(err error) (ProgramError, bool)

func NewProgramError

func NewProgramError(v Value, callstack []CallFrame, extra map[string]string) ProgramError

func ProgramErrorFromProto

func ProgramErrorFromProto(m *ProgramErrorPB) (ProgramError, error)

func StrictProgramErrorFromProto

func StrictProgramErrorFromProto(m *ProgramErrorPB) (ProgramError, error)

func WrapError added in v0.3.0

func WrapError(err error) ProgramError

func (ProgramError) CallStack added in v0.3.0

func (e ProgramError) CallStack() []CallFrame

func (ProgramError) Equal added in v0.3.0

func (o ProgramError) Equal(other interface{ ToProto() M }) bool

func (ProgramError) ErrorString added in v0.3.0

func (e ProgramError) ErrorString() string

func (ProgramError) Extra added in v0.3.0

func (e ProgramError) Extra() map[string]string

func (ProgramError) Hash added in v0.3.0

func (o ProgramError) Hash() string

func (ProgramError) IsValid added in v0.3.0

func (o ProgramError) IsValid() bool

func (ProgramError) MarshalJSON added in v0.3.0

func (o ProgramError) MarshalJSON() ([]byte, error)

func (ProgramError) Message added in v0.3.0

func (o ProgramError) Message() proto.Message

func (ProgramError) Strict added in v0.3.0

func (o ProgramError) Strict() error

func (ProgramError) String added in v0.3.0

func (o ProgramError) String() string

func (ProgramError) ToError added in v0.3.0

func (p ProgramError) ToError() (err error)

func (ProgramError) ToProto added in v0.3.0

func (o ProgramError) ToProto() M

func (*ProgramError) UnmarshalJSON added in v0.3.0

func (o *ProgramError) UnmarshalJSON(b []byte) (err error)

func (ProgramError) Value added in v0.3.0

func (e ProgramError) Value() Value

type ProgramErrorPB

type ProgramErrorPB = programv1.Error

type ProgramErrorTraits added in v0.3.0

type ProgramErrorTraits struct{}

func (ProgramErrorTraits) StrictValidate added in v0.3.0

func (ProgramErrorTraits) StrictValidate(m *ProgramErrorPB) error

func (ProgramErrorTraits) Validate added in v0.3.0

type Project

type Project struct {
	// contains filtered or unexported fields
}
var InvalidProject Project

func NewProject added in v0.3.0

func NewProject() Project

func ProjectFromProto

func ProjectFromProto(m *ProjectPB) (Project, error)

func StrictProjectFromProto

func StrictProjectFromProto(m *ProjectPB) (Project, error)

func (Project) Equal added in v0.3.0

func (o Project) Equal(other interface{ ToProto() M }) bool

func (Project) Hash added in v0.3.0

func (o Project) Hash() string

func (Project) ID added in v0.3.0

func (p Project) ID() ProjectID

func (Project) IsValid added in v0.3.0

func (o Project) IsValid() bool

func (Project) MarshalJSON added in v0.3.0

func (o Project) MarshalJSON() ([]byte, error)

func (Project) Message added in v0.3.0

func (o Project) Message() proto.Message

func (Project) Name added in v0.3.0

func (p Project) Name() Symbol

func (Project) Strict added in v0.3.0

func (o Project) Strict() error

func (Project) String added in v0.3.0

func (o Project) String() string

func (Project) ToProto added in v0.3.0

func (o Project) ToProto() M

func (*Project) UnmarshalJSON added in v0.3.0

func (o *Project) UnmarshalJSON(b []byte) (err error)

func (Project) WithID added in v0.3.0

func (p Project) WithID(id ProjectID) Project

func (Project) WithName added in v0.3.0

func (p Project) WithName(name Symbol) Project

func (Project) WithNewID added in v0.3.0

func (p Project) WithNewID() Project

type ProjectID

type ProjectID = id[projectIDTraits]
var InvalidProjectID ProjectID

func NewProjectID

func NewProjectID() ProjectID

func ParseProjectID

func ParseProjectID(s string) (ProjectID, error)

func StrictParseProjectID

func StrictParseProjectID(s string) (ProjectID, error)

type ProjectPB

type ProjectPB = projectv1.Project

type ProjectTraits added in v0.3.0

type ProjectTraits struct{}

func (ProjectTraits) StrictValidate added in v0.3.0

func (ProjectTraits) StrictValidate(m *ProjectPB) error

func (ProjectTraits) Validate added in v0.3.0

func (ProjectTraits) Validate(m *ProjectPB) error

type RunID

type RunID = id[runIDTraits]

func NewRunID

func NewRunID() RunID

func ParseRunID

func ParseRunID(s string) (RunID, error)

type Runtime

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

func RuntimeFromProto

func RuntimeFromProto(m *RuntimePB) (Runtime, error)

func StrictRuntimeFromProto

func StrictRuntimeFromProto(m *RuntimePB) (Runtime, error)

func (Runtime) Equal added in v0.3.0

func (o Runtime) Equal(other interface{ ToProto() M }) bool

func (Runtime) FileExtensions added in v0.3.0

func (r Runtime) FileExtensions() []string

func (Runtime) Hash added in v0.3.0

func (o Runtime) Hash() string

func (Runtime) IsValid added in v0.3.0

func (o Runtime) IsValid() bool

func (Runtime) MarshalJSON added in v0.3.0

func (o Runtime) MarshalJSON() ([]byte, error)

func (Runtime) Message added in v0.3.0

func (o Runtime) Message() proto.Message

func (Runtime) Name added in v0.3.0

func (r Runtime) Name() Symbol

func (Runtime) Strict added in v0.3.0

func (o Runtime) Strict() error

func (Runtime) String added in v0.3.0

func (o Runtime) String() string

func (Runtime) ToProto added in v0.3.0

func (o Runtime) ToProto() M

func (*Runtime) UnmarshalJSON added in v0.3.0

func (o *Runtime) UnmarshalJSON(b []byte) (err error)

type RuntimePB

type RuntimePB = runtimev1.Runtime

type RuntimeTraits added in v0.3.0

type RuntimeTraits struct{}

func (RuntimeTraits) StrictValidate added in v0.3.0

func (RuntimeTraits) StrictValidate(m *RuntimePB) error

func (RuntimeTraits) Validate added in v0.3.0

func (RuntimeTraits) Validate(m *RuntimePB) error

type Session

type Session struct {
	// contains filtered or unexported fields
}
var InvalidSession Session

func NewSession

func NewSession(buildID BuildID, ep CodeLocation, inputs map[string]Value, memo map[string]string) Session

func SessionFromProto

func SessionFromProto(m *SessionPB) (Session, error)

func StrictSessionFromProto

func StrictSessionFromProto(m *SessionPB) (Session, error)

func (Session) BuildID added in v0.4.0

func (p Session) BuildID() BuildID

func (Session) DeploymentID added in v0.3.0

func (p Session) DeploymentID() DeploymentID

func (Session) EntryPoint added in v0.3.0

func (p Session) EntryPoint() CodeLocation

func (Session) EnvID added in v0.4.0

func (p Session) EnvID() EnvID

func (Session) Equal added in v0.3.0

func (o Session) Equal(other interface{ ToProto() M }) bool

func (Session) EventID added in v0.3.0

func (p Session) EventID() EventID

func (Session) Hash added in v0.3.0

func (o Session) Hash() string

func (Session) ID added in v0.3.0

func (p Session) ID() SessionID

func (Session) Inputs added in v0.3.0

func (p Session) Inputs() map[string]Value

func (Session) IsValid added in v0.3.0

func (o Session) IsValid() bool

func (Session) MarshalJSON added in v0.3.0

func (o Session) MarshalJSON() ([]byte, error)

func (Session) Memo added in v0.3.0

func (p Session) Memo() map[string]string

func (Session) Message added in v0.3.0

func (o Session) Message() proto.Message

func (Session) State added in v0.3.0

func (p Session) State() SessionStateType

func (Session) Strict added in v0.3.0

func (o Session) Strict() error

func (Session) String added in v0.3.0

func (o Session) String() string

func (Session) ToProto added in v0.3.0

func (o Session) ToProto() M

func (*Session) UnmarshalJSON added in v0.3.0

func (o *Session) UnmarshalJSON(b []byte) (err error)

func (Session) WithBuildID added in v0.4.0

func (s Session) WithBuildID(id BuildID) Session

func (Session) WithDeploymentID added in v0.4.0

func (s Session) WithDeploymentID(id DeploymentID) Session

func (Session) WithEndpoint added in v0.4.0

func (s Session) WithEndpoint(ep CodeLocation) Session

func (Session) WithEnvID added in v0.4.0

func (s Session) WithEnvID(id EnvID) Session

func (Session) WithEventID added in v0.4.0

func (s Session) WithEventID(id EventID) Session

func (Session) WithInptus added in v0.6.0

func (s Session) WithInptus(inputs map[string]Value) Session

func (Session) WithInputs added in v0.3.0

func (p Session) WithInputs(inputs map[string]Value) Session

func (Session) WithNewID added in v0.3.0

func (p Session) WithNewID() Session

func (Session) WithParentSessionID added in v0.4.0

func (s Session) WithParentSessionID(id SessionID) Session

type SessionCall

type SessionCall struct {
	// contains filtered or unexported fields
}
var InvalidSessionCall SessionCall

func SessionCallFromProto

func SessionCallFromProto(m *SessionCallPB) (SessionCall, error)

func StrictSessionCallFromProto

func StrictSessionCallFromProto(m *SessionCallPB) (SessionCall, error)

func (SessionCall) Equal added in v0.3.0

func (o SessionCall) Equal(other interface{ ToProto() M }) bool

func (SessionCall) Hash added in v0.3.0

func (o SessionCall) Hash() string

func (SessionCall) IsValid added in v0.3.0

func (o SessionCall) IsValid() bool

func (SessionCall) MarshalJSON added in v0.3.0

func (o SessionCall) MarshalJSON() ([]byte, error)

func (SessionCall) Message added in v0.3.0

func (o SessionCall) Message() proto.Message

func (SessionCall) Strict added in v0.3.0

func (o SessionCall) Strict() error

func (SessionCall) String added in v0.3.0

func (o SessionCall) String() string

func (SessionCall) ToProto added in v0.3.0

func (o SessionCall) ToProto() M

func (*SessionCall) UnmarshalJSON added in v0.3.0

func (o *SessionCall) UnmarshalJSON(b []byte) (err error)

type SessionCallAttempt added in v0.3.0

type SessionCallAttempt struct {
	// contains filtered or unexported fields
}
var InvalidSessionCallAttempt SessionCallAttempt

func SessionCallAttemptFromProto added in v0.3.0

func SessionCallAttemptFromProto(m *SessionCallAttemptPB) (SessionCallAttempt, error)

func StrictSessionCallAttemptFromProto added in v0.3.0

func StrictSessionCallAttemptFromProto(m *SessionCallAttemptPB) (SessionCallAttempt, error)

func (SessionCallAttempt) Equal added in v0.3.0

func (o SessionCallAttempt) Equal(other interface{ ToProto() M }) bool

func (SessionCallAttempt) Hash added in v0.3.0

func (o SessionCallAttempt) Hash() string

func (SessionCallAttempt) IsValid added in v0.3.0

func (o SessionCallAttempt) IsValid() bool

func (SessionCallAttempt) MarshalJSON added in v0.3.0

func (o SessionCallAttempt) MarshalJSON() ([]byte, error)

func (SessionCallAttempt) Message added in v0.3.0

func (o SessionCallAttempt) Message() proto.Message

func (SessionCallAttempt) Strict added in v0.3.0

func (o SessionCallAttempt) Strict() error

func (SessionCallAttempt) String added in v0.3.0

func (o SessionCallAttempt) String() string

func (SessionCallAttempt) ToProto added in v0.3.0

func (o SessionCallAttempt) ToProto() M

func (*SessionCallAttempt) UnmarshalJSON added in v0.3.0

func (o *SessionCallAttempt) UnmarshalJSON(b []byte) (err error)

type SessionCallAttemptComplete

type SessionCallAttemptComplete struct {
	// contains filtered or unexported fields
}
var InvalidSessionCallAttemptComplete SessionCallAttemptComplete

func NewSessionCallAttemptComplete

func NewSessionCallAttemptComplete(last bool, interval time.Duration, result SessionCallAttemptResult) SessionCallAttemptComplete

func NewSessionLogCallAttemptComplete

func NewSessionLogCallAttemptComplete(complete SessionCallAttemptComplete) SessionCallAttemptComplete

func (SessionCallAttemptComplete) Equal added in v0.3.0

func (o SessionCallAttemptComplete) Equal(other interface{ ToProto() M }) bool

func (SessionCallAttemptComplete) Hash added in v0.3.0

func (o SessionCallAttemptComplete) Hash() string

func (SessionCallAttemptComplete) IsValid added in v0.3.0

func (o SessionCallAttemptComplete) IsValid() bool

func (SessionCallAttemptComplete) MarshalJSON added in v0.3.0

func (o SessionCallAttemptComplete) MarshalJSON() ([]byte, error)

func (SessionCallAttemptComplete) Message added in v0.3.0

func (o SessionCallAttemptComplete) Message() proto.Message

func (SessionCallAttemptComplete) Result added in v0.3.0

func (SessionCallAttemptComplete) Strict added in v0.3.0

func (o SessionCallAttemptComplete) Strict() error

func (SessionCallAttemptComplete) String added in v0.3.0

func (o SessionCallAttemptComplete) String() string

func (SessionCallAttemptComplete) ToProto added in v0.3.0

func (o SessionCallAttemptComplete) ToProto() M

func (*SessionCallAttemptComplete) UnmarshalJSON added in v0.3.0

func (o *SessionCallAttemptComplete) UnmarshalJSON(b []byte) (err error)

type SessionCallAttemptCompletePB

type SessionCallAttemptCompletePB = sessionv1.Call_Attempt_Complete

type SessionCallAttemptCompleteTraits added in v0.3.0

type SessionCallAttemptCompleteTraits struct{}

func (SessionCallAttemptCompleteTraits) StrictValidate added in v0.3.0

func (SessionCallAttemptCompleteTraits) Validate added in v0.3.0

type SessionCallAttemptPB added in v0.3.0

type SessionCallAttemptPB = sessionv1.Call_Attempt

type SessionCallAttemptResult

type SessionCallAttemptResult struct {
	// contains filtered or unexported fields
}
var InvalidSessionCallAttemptResult SessionCallAttemptResult

func NewSessionCallAttemptResult

func NewSessionCallAttemptResult(v Value, err error) SessionCallAttemptResult

func (SessionCallAttemptResult) Equal added in v0.3.0

func (o SessionCallAttemptResult) Equal(other interface{ ToProto() M }) bool

func (SessionCallAttemptResult) GetError added in v0.3.0

func (r SessionCallAttemptResult) GetError() error

func (SessionCallAttemptResult) GetValue added in v0.3.0

func (r SessionCallAttemptResult) GetValue() Value

func (SessionCallAttemptResult) Hash added in v0.3.0

func (o SessionCallAttemptResult) Hash() string

func (SessionCallAttemptResult) IsValid added in v0.3.0

func (o SessionCallAttemptResult) IsValid() bool

func (SessionCallAttemptResult) MarshalJSON added in v0.3.0

func (o SessionCallAttemptResult) MarshalJSON() ([]byte, error)

func (SessionCallAttemptResult) Message added in v0.3.0

func (o SessionCallAttemptResult) Message() proto.Message

func (SessionCallAttemptResult) Strict added in v0.3.0

func (o SessionCallAttemptResult) Strict() error

func (SessionCallAttemptResult) String added in v0.3.0

func (o SessionCallAttemptResult) String() string

func (SessionCallAttemptResult) ToPair added in v0.3.0

func (r SessionCallAttemptResult) ToPair() (Value, error)

func (SessionCallAttemptResult) ToProto added in v0.3.0

func (o SessionCallAttemptResult) ToProto() M

func (SessionCallAttemptResult) ToValueTuple added in v0.3.2

func (r SessionCallAttemptResult) ToValueTuple() Value

func (*SessionCallAttemptResult) UnmarshalJSON added in v0.3.0

func (o *SessionCallAttemptResult) UnmarshalJSON(b []byte) (err error)

type SessionCallAttemptResultPB

type SessionCallAttemptResultPB = sessionv1.Call_Attempt_Result

type SessionCallAttemptResultTraits added in v0.3.0

type SessionCallAttemptResultTraits struct{}

func (SessionCallAttemptResultTraits) StrictValidate added in v0.3.0

func (SessionCallAttemptResultTraits) Validate added in v0.3.0

type SessionCallAttemptStart

type SessionCallAttemptStart struct {
	// contains filtered or unexported fields
}
var InvalidSessionCallAttemptStart SessionCallAttemptStart

func StrictSessionCallAttemptStartFromProto

func StrictSessionCallAttemptStartFromProto(m *SessionCallAttemptStartPB) (SessionCallAttemptStart, error)

func (SessionCallAttemptStart) Equal added in v0.3.0

func (o SessionCallAttemptStart) Equal(other interface{ ToProto() M }) bool

func (SessionCallAttemptStart) Hash added in v0.3.0

func (o SessionCallAttemptStart) Hash() string

func (SessionCallAttemptStart) IsValid added in v0.3.0

func (o SessionCallAttemptStart) IsValid() bool

func (SessionCallAttemptStart) MarshalJSON added in v0.3.0

func (o SessionCallAttemptStart) MarshalJSON() ([]byte, error)

func (SessionCallAttemptStart) Message added in v0.3.0

func (o SessionCallAttemptStart) Message() proto.Message

func (SessionCallAttemptStart) Strict added in v0.3.0

func (o SessionCallAttemptStart) Strict() error

func (SessionCallAttemptStart) String added in v0.3.0

func (o SessionCallAttemptStart) String() string

func (SessionCallAttemptStart) ToProto added in v0.3.0

func (o SessionCallAttemptStart) ToProto() M

func (*SessionCallAttemptStart) UnmarshalJSON added in v0.3.0

func (o *SessionCallAttemptStart) UnmarshalJSON(b []byte) (err error)

type SessionCallAttemptStartPB

type SessionCallAttemptStartPB = sessionv1.Call_Attempt_Start

type SessionCallAttemptStartTraits added in v0.3.0

type SessionCallAttemptStartTraits struct{}

func (SessionCallAttemptStartTraits) StrictValidate added in v0.3.0

func (SessionCallAttemptStartTraits) Validate added in v0.3.0

type SessionCallAttemptTraits added in v0.3.0

type SessionCallAttemptTraits struct{}

func (SessionCallAttemptTraits) StrictValidate added in v0.3.0

func (SessionCallAttemptTraits) Validate added in v0.3.0

type SessionCallPB

type SessionCallPB = sessionv1.Call

type SessionCallSpec

type SessionCallSpec struct {
	// contains filtered or unexported fields
}
var InvalidSessionCallSpec SessionCallSpec

func NewSessionCallSpec

func NewSessionCallSpec(function Value, args []Value, kwargs map[string]Value, seq uint32) SessionCallSpec

func SessionCallSpecFromProto

func SessionCallSpecFromProto(m *SessionCallSpecPB) (SessionCallSpec, error)

func StrictSessionCallSpecFromProto

func StrictSessionCallSpecFromProto(m *SessionCallSpecPB) (SessionCallSpec, error)

func (SessionCallSpec) Data added in v0.3.0

func (p SessionCallSpec) Data() (Value, []Value, map[string]Value)

func (SessionCallSpec) Equal added in v0.3.0

func (o SessionCallSpec) Equal(other interface{ ToProto() M }) bool

func (SessionCallSpec) Hash added in v0.3.0

func (o SessionCallSpec) Hash() string

func (SessionCallSpec) IsValid added in v0.3.0

func (o SessionCallSpec) IsValid() bool

func (SessionCallSpec) MarshalJSON added in v0.3.0

func (o SessionCallSpec) MarshalJSON() ([]byte, error)

func (SessionCallSpec) Message added in v0.3.0

func (o SessionCallSpec) Message() proto.Message

func (SessionCallSpec) Seq added in v0.3.0

func (p SessionCallSpec) Seq() uint32

func (SessionCallSpec) Strict added in v0.3.0

func (o SessionCallSpec) Strict() error

func (SessionCallSpec) String added in v0.3.0

func (o SessionCallSpec) String() string

func (SessionCallSpec) ToProto added in v0.3.0

func (o SessionCallSpec) ToProto() M

func (*SessionCallSpec) UnmarshalJSON added in v0.3.0

func (o *SessionCallSpec) UnmarshalJSON(b []byte) (err error)

type SessionCallSpecPB

type SessionCallSpecPB = sessionv1.Call_Spec

type SessionCallSpecTraits added in v0.3.0

type SessionCallSpecTraits struct{}

func (SessionCallSpecTraits) StrictValidate added in v0.3.0

func (SessionCallSpecTraits) StrictValidate(m *SessionCallSpecPB) error

func (SessionCallSpecTraits) Validate added in v0.3.0

type SessionCallTraits added in v0.3.0

type SessionCallTraits struct{}

func (SessionCallTraits) StrictValidate added in v0.3.0

func (SessionCallTraits) StrictValidate(m *SessionCallPB) error

func (SessionCallTraits) Validate added in v0.3.0

func (SessionCallTraits) Validate(m *SessionCallPB) error

type SessionID

type SessionID = id[sessionIDTraits]
var InvalidSessionID SessionID

func NewSessionID

func NewSessionID() SessionID

func ParseSessionID

func ParseSessionID(s string) (SessionID, error)

func StrictParseSessionID

func StrictParseSessionID(s string) (SessionID, error)

type SessionLog

type SessionLog struct {
	// contains filtered or unexported fields
}
var InvalidSessionLog SessionLog

func NewSessionLog

func NewSessionLog(rs []SessionLogRecord) SessionLog

func SessionLogFromProto

func SessionLogFromProto(m *SessionLogPB) (SessionLog, error)

func StrictSessionLogFromProto

func StrictSessionLogFromProto(m *SessionLogPB) (SessionLog, error)

func (SessionLog) Equal added in v0.3.0

func (o SessionLog) Equal(other interface{ ToProto() M }) bool

func (SessionLog) Hash added in v0.3.0

func (o SessionLog) Hash() string

func (SessionLog) IsValid added in v0.3.0

func (o SessionLog) IsValid() bool

func (SessionLog) MarshalJSON added in v0.3.0

func (o SessionLog) MarshalJSON() ([]byte, error)

func (SessionLog) Message added in v0.3.0

func (o SessionLog) Message() proto.Message

func (SessionLog) Records added in v0.4.0

func (l SessionLog) Records() []SessionLogRecord

func (SessionLog) Strict added in v0.3.0

func (o SessionLog) Strict() error

func (SessionLog) String added in v0.3.0

func (o SessionLog) String() string

func (SessionLog) ToProto added in v0.3.0

func (o SessionLog) ToProto() M

func (*SessionLog) UnmarshalJSON added in v0.3.0

func (o *SessionLog) UnmarshalJSON(b []byte) (err error)

type SessionLogPB

type SessionLogPB = sessionv1.SessionLog

type SessionLogRecord

type SessionLogRecord struct {
	// contains filtered or unexported fields
}
var InvalidSessionLogRecord SessionLogRecord

func NewCallAttemptCompleteSessionLogRecord

func NewCallAttemptCompleteSessionLogRecord(s SessionCallAttemptComplete) SessionLogRecord

func NewCallAttemptStartSessionLogRecord

func NewCallAttemptStartSessionLogRecord(s SessionCallAttemptStart) SessionLogRecord

func NewCallSpecSessionLogRecord

func NewCallSpecSessionLogRecord(s SessionCallSpec) SessionLogRecord

func NewPrintSessionLogRecord

func NewPrintSessionLogRecord(text string) SessionLogRecord

func NewStateSessionLogRecord

func NewStateSessionLogRecord(state SessionState) SessionLogRecord

func NewStopRequestSessionLogRecord added in v0.4.0

func NewStopRequestSessionLogRecord(reason string) SessionLogRecord

func SessionLogRecordFromProto

func SessionLogRecordFromProto(m *SessionLogRecordPB) (SessionLogRecord, error)

func StrictSessionLogRecordFromProto

func StrictSessionLogRecordFromProto(m *SessionLogRecordPB) (SessionLogRecord, error)

func (SessionLogRecord) Equal added in v0.3.0

func (o SessionLogRecord) Equal(other interface{ ToProto() M }) bool

func (SessionLogRecord) GetPrint added in v0.4.0

func (s SessionLogRecord) GetPrint() (string, bool)

func (SessionLogRecord) GetState added in v0.5.0

func (s SessionLogRecord) GetState() SessionState

func (SessionLogRecord) GetStopRequest added in v0.4.0

func (s SessionLogRecord) GetStopRequest() (string, bool)

func (SessionLogRecord) Hash added in v0.3.0

func (o SessionLogRecord) Hash() string

func (SessionLogRecord) IsValid added in v0.3.0

func (o SessionLogRecord) IsValid() bool

func (SessionLogRecord) MarshalJSON added in v0.3.0

func (o SessionLogRecord) MarshalJSON() ([]byte, error)

func (SessionLogRecord) Message added in v0.3.0

func (o SessionLogRecord) Message() proto.Message

func (SessionLogRecord) Strict added in v0.3.0

func (o SessionLogRecord) Strict() error

func (SessionLogRecord) String added in v0.3.0

func (o SessionLogRecord) String() string

func (SessionLogRecord) Timestamp added in v0.4.0

func (r SessionLogRecord) Timestamp() time.Time

func (SessionLogRecord) ToProto added in v0.3.0

func (o SessionLogRecord) ToProto() M

func (*SessionLogRecord) UnmarshalJSON added in v0.3.0

func (o *SessionLogRecord) UnmarshalJSON(b []byte) (err error)

func (SessionLogRecord) WithProcessID added in v0.4.6

func (r SessionLogRecord) WithProcessID(pid string) SessionLogRecord

func (SessionLogRecord) WithoutTimestamp added in v0.4.0

func (r SessionLogRecord) WithoutTimestamp() SessionLogRecord

type SessionLogRecordPB

type SessionLogRecordPB = sessionv1.SessionLogRecord

type SessionLogRecordTraits added in v0.3.0

type SessionLogRecordTraits struct{}

func (SessionLogRecordTraits) StrictValidate added in v0.3.0

func (SessionLogRecordTraits) StrictValidate(m *SessionLogRecordPB) error

func (SessionLogRecordTraits) Validate added in v0.3.0

type SessionLogTraits added in v0.3.0

type SessionLogTraits struct{}

func (SessionLogTraits) StrictValidate added in v0.3.0

func (SessionLogTraits) StrictValidate(m *SessionLogPB) error

func (SessionLogTraits) Validate added in v0.3.0

func (SessionLogTraits) Validate(m *SessionLogPB) error

type SessionPB

type SessionPB = sessionv1.Session

type SessionState

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

func NewSessionState added in v0.3.0

func NewSessionState(t time.Time, concrete concreteSessionState) SessionState

func NewSessionStateCompleted added in v0.3.0

func NewSessionStateCompleted(prints []string, exports map[string]Value, ret Value) SessionState

func NewSessionStateCreated added in v0.3.0

func NewSessionStateCreated() SessionState

func NewSessionStateError added in v0.3.0

func NewSessionStateError(err error, prints []string) SessionState

func NewSessionStateRunning added in v0.3.0

func NewSessionStateRunning(rid RunID, callValue Value) SessionState

func NewSessionStateStopped added in v0.4.0

func NewSessionStateStopped(reason string) SessionState

func SessionStateFromProto

func SessionStateFromProto(m *SessionStatePB) (SessionState, error)

func StrictSessionStateFromProto

func StrictSessionStateFromProto(m *SessionStatePB) (SessionState, error)

func (SessionState) Concrete added in v0.3.0

func (p SessionState) Concrete() concreteSessionState

func (SessionState) Equal added in v0.3.0

func (o SessionState) Equal(other interface{ ToProto() M }) bool

func (SessionState) GetCompleted added in v0.3.0

func (s SessionState) GetCompleted() SessionStateCompleted

func (SessionState) GetCreated added in v0.3.0

func (s SessionState) GetCreated() SessionStateCreated

func (SessionState) GetError added in v0.3.0

func (s SessionState) GetError() SessionStateError

func (SessionState) GetRunning added in v0.3.0

func (s SessionState) GetRunning() SessionStateRunning

func (SessionState) GetStopped added in v0.4.0

func (s SessionState) GetStopped() SessionStateStopped

func (SessionState) Hash added in v0.3.0

func (o SessionState) Hash() string

func (SessionState) IsValid added in v0.3.0

func (o SessionState) IsValid() bool

func (SessionState) MarshalJSON added in v0.3.0

func (o SessionState) MarshalJSON() ([]byte, error)

func (SessionState) Message added in v0.3.0

func (o SessionState) Message() proto.Message

func (SessionState) Strict added in v0.3.0

func (o SessionState) Strict() error

func (SessionState) String added in v0.3.0

func (o SessionState) String() string

func (SessionState) ToProto added in v0.3.0

func (o SessionState) ToProto() M

func (SessionState) Type added in v0.3.0

func (p SessionState) Type() SessionStateType

func (*SessionState) UnmarshalJSON added in v0.3.0

func (o *SessionState) UnmarshalJSON(b []byte) (err error)

type SessionStateCompleted added in v0.3.0

type SessionStateCompleted struct {
	// contains filtered or unexported fields
}
var InvalidSessionStateCompleted SessionStateCompleted

func SessionStateCompletedFromProto added in v0.3.0

func SessionStateCompletedFromProto(m *SessionStateCompletedPB) (SessionStateCompleted, error)

func StrictSessionStateCompletedFromProto added in v0.3.0

func StrictSessionStateCompletedFromProto(m *SessionStateCompletedPB) (SessionStateCompleted, error)

func (SessionStateCompleted) Equal added in v0.3.0

func (o SessionStateCompleted) Equal(other interface{ ToProto() M }) bool

func (SessionStateCompleted) Hash added in v0.3.0

func (o SessionStateCompleted) Hash() string

func (SessionStateCompleted) IsValid added in v0.3.0

func (o SessionStateCompleted) IsValid() bool

func (SessionStateCompleted) MarshalJSON added in v0.3.0

func (o SessionStateCompleted) MarshalJSON() ([]byte, error)

func (SessionStateCompleted) Message added in v0.3.0

func (o SessionStateCompleted) Message() proto.Message

func (SessionStateCompleted) Strict added in v0.3.0

func (o SessionStateCompleted) Strict() error

func (SessionStateCompleted) String added in v0.3.0

func (o SessionStateCompleted) String() string

func (SessionStateCompleted) ToProto added in v0.3.0

func (o SessionStateCompleted) ToProto() M

func (*SessionStateCompleted) UnmarshalJSON added in v0.3.0

func (o *SessionStateCompleted) UnmarshalJSON(b []byte) (err error)

type SessionStateCompletedPB added in v0.3.0

type SessionStateCompletedPB = sessionv1.SessionState_Completed

type SessionStateCompletedTraits added in v0.3.0

type SessionStateCompletedTraits struct{}

func (SessionStateCompletedTraits) StrictValidate added in v0.3.0

func (SessionStateCompletedTraits) Validate added in v0.3.0

type SessionStateCreated added in v0.3.0

type SessionStateCreated struct {
	// contains filtered or unexported fields
}
var InvalidSessionStateCreated SessionStateCreated

func SessionStateCreatedFromProto added in v0.3.0

func SessionStateCreatedFromProto(m *SessionStateCreatedPB) (SessionStateCreated, error)

func StrictSessionStateCreatedFromProto added in v0.3.0

func StrictSessionStateCreatedFromProto(m *SessionStateCreatedPB) (SessionStateCreated, error)

func (SessionStateCreated) Equal added in v0.3.0

func (o SessionStateCreated) Equal(other interface{ ToProto() M }) bool

func (SessionStateCreated) Hash added in v0.3.0

func (o SessionStateCreated) Hash() string

func (SessionStateCreated) IsValid added in v0.3.0

func (o SessionStateCreated) IsValid() bool

func (SessionStateCreated) MarshalJSON added in v0.3.0

func (o SessionStateCreated) MarshalJSON() ([]byte, error)

func (SessionStateCreated) Message added in v0.3.0

func (o SessionStateCreated) Message() proto.Message

func (SessionStateCreated) Strict added in v0.3.0

func (o SessionStateCreated) Strict() error

func (SessionStateCreated) String added in v0.3.0

func (o SessionStateCreated) String() string

func (SessionStateCreated) ToProto added in v0.3.0

func (o SessionStateCreated) ToProto() M

func (*SessionStateCreated) UnmarshalJSON added in v0.3.0

func (o *SessionStateCreated) UnmarshalJSON(b []byte) (err error)

type SessionStateCreatedPB added in v0.3.0

type SessionStateCreatedPB = sessionv1.SessionState_Created

type SessionStateCreatedTraits added in v0.3.0

type SessionStateCreatedTraits struct{}

func (SessionStateCreatedTraits) StrictValidate added in v0.3.0

func (SessionStateCreatedTraits) Validate added in v0.3.0

type SessionStateError added in v0.3.0

type SessionStateError struct {
	// contains filtered or unexported fields
}
var InvalidSessionStateError SessionStateError

func SessionStateErrorFromProto added in v0.3.0

func SessionStateErrorFromProto(m *SessionStateErrorPB) (SessionStateError, error)

func StrictSessionStateErrorFromProto added in v0.3.0

func StrictSessionStateErrorFromProto(m *SessionStateErrorPB) (SessionStateError, error)

func (SessionStateError) Equal added in v0.3.0

func (o SessionStateError) Equal(other interface{ ToProto() M }) bool

func (SessionStateError) GetProgramError added in v0.5.0

func (se SessionStateError) GetProgramError() ProgramError

func (SessionStateError) Hash added in v0.3.0

func (o SessionStateError) Hash() string

func (SessionStateError) IsValid added in v0.3.0

func (o SessionStateError) IsValid() bool

func (SessionStateError) MarshalJSON added in v0.3.0

func (o SessionStateError) MarshalJSON() ([]byte, error)

func (SessionStateError) Message added in v0.3.0

func (o SessionStateError) Message() proto.Message

func (SessionStateError) Strict added in v0.3.0

func (o SessionStateError) Strict() error

func (SessionStateError) String added in v0.3.0

func (o SessionStateError) String() string

func (SessionStateError) ToProto added in v0.3.0

func (o SessionStateError) ToProto() M

func (*SessionStateError) UnmarshalJSON added in v0.3.0

func (o *SessionStateError) UnmarshalJSON(b []byte) (err error)

type SessionStateErrorPB added in v0.3.0

type SessionStateErrorPB = sessionv1.SessionState_Error

type SessionStateErrorTraits added in v0.3.0

type SessionStateErrorTraits struct{}

func (SessionStateErrorTraits) StrictValidate added in v0.3.0

func (SessionStateErrorTraits) Validate added in v0.3.0

type SessionStatePB

type SessionStatePB = sessionv1.SessionState

type SessionStateRunning added in v0.3.0

type SessionStateRunning struct {
	// contains filtered or unexported fields
}
var InvalidSessionStateRunning SessionStateRunning

func SessionStateRunningFromProto added in v0.3.0

func SessionStateRunningFromProto(m *SessionStateRunningPB) (SessionStateRunning, error)

func StrictSessionStateRunningFromProto added in v0.3.0

func StrictSessionStateRunningFromProto(m *SessionStateRunningPB) (SessionStateRunning, error)

func (SessionStateRunning) Call added in v0.3.2

func (s SessionStateRunning) Call() Value

func (SessionStateRunning) Equal added in v0.3.0

func (o SessionStateRunning) Equal(other interface{ ToProto() M }) bool

func (SessionStateRunning) Hash added in v0.3.0

func (o SessionStateRunning) Hash() string

func (SessionStateRunning) IsValid added in v0.3.0

func (o SessionStateRunning) IsValid() bool

func (SessionStateRunning) MarshalJSON added in v0.3.0

func (o SessionStateRunning) MarshalJSON() ([]byte, error)

func (SessionStateRunning) Message added in v0.3.0

func (o SessionStateRunning) Message() proto.Message

func (SessionStateRunning) Strict added in v0.3.0

func (o SessionStateRunning) Strict() error

func (SessionStateRunning) String added in v0.3.0

func (o SessionStateRunning) String() string

func (SessionStateRunning) ToProto added in v0.3.0

func (o SessionStateRunning) ToProto() M

func (*SessionStateRunning) UnmarshalJSON added in v0.3.0

func (o *SessionStateRunning) UnmarshalJSON(b []byte) (err error)

type SessionStateRunningPB added in v0.3.0

type SessionStateRunningPB = sessionv1.SessionState_Running

type SessionStateRunningTraits added in v0.3.0

type SessionStateRunningTraits struct{}

func (SessionStateRunningTraits) StrictValidate added in v0.3.0

func (SessionStateRunningTraits) Validate added in v0.3.0

type SessionStateStopped added in v0.4.0

type SessionStateStopped struct {
	// contains filtered or unexported fields
}
var InvalidSessionStateStopped SessionStateStopped

func SessionStateStoppedFromProto added in v0.4.0

func SessionStateStoppedFromProto(m *SessionStateStoppedPB) (SessionStateStopped, error)

func StrictSessionStateStoppedFromProto added in v0.4.0

func StrictSessionStateStoppedFromProto(m *SessionStateStoppedPB) (SessionStateStopped, error)

func (SessionStateStopped) Equal added in v0.4.0

func (o SessionStateStopped) Equal(other interface{ ToProto() M }) bool

func (SessionStateStopped) Hash added in v0.4.0

func (o SessionStateStopped) Hash() string

func (SessionStateStopped) IsValid added in v0.4.0

func (o SessionStateStopped) IsValid() bool

func (SessionStateStopped) MarshalJSON added in v0.4.0

func (o SessionStateStopped) MarshalJSON() ([]byte, error)

func (SessionStateStopped) Message added in v0.4.0

func (o SessionStateStopped) Message() proto.Message

func (SessionStateStopped) Strict added in v0.4.0

func (o SessionStateStopped) Strict() error

func (SessionStateStopped) String added in v0.4.0

func (o SessionStateStopped) String() string

func (SessionStateStopped) ToProto added in v0.4.0

func (o SessionStateStopped) ToProto() M

func (*SessionStateStopped) UnmarshalJSON added in v0.4.0

func (o *SessionStateStopped) UnmarshalJSON(b []byte) (err error)

type SessionStateStoppedPB added in v0.4.0

type SessionStateStoppedPB = sessionv1.SessionState_Stopped

type SessionStateStoppedTraits added in v0.4.0

type SessionStateStoppedTraits struct{}

func (SessionStateStoppedTraits) StrictValidate added in v0.4.0

func (SessionStateStoppedTraits) Validate added in v0.4.0

type SessionStateTraits added in v0.3.0

type SessionStateTraits struct{}

func (SessionStateTraits) StrictValidate added in v0.3.0

func (SessionStateTraits) StrictValidate(m *SessionStatePB) error

func (SessionStateTraits) Validate added in v0.3.0

type SessionStateType

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

func ParseSessionStateType

func ParseSessionStateType(raw string) (SessionStateType, error)

func (SessionStateType) IsFinal added in v0.4.0

func (e SessionStateType) IsFinal() bool

func (SessionStateType) IsZero added in v0.3.0

func (e SessionStateType) IsZero() bool

func (SessionStateType) MarshalJSON added in v0.3.0

func (e SessionStateType) MarshalJSON() ([]byte, error)

func (SessionStateType) Prefix added in v0.3.0

func (e SessionStateType) Prefix() string

func (SessionStateType) Strict added in v0.3.0

func (e SessionStateType) Strict() error

func (SessionStateType) String

func (e SessionStateType) String() string

func (SessionStateType) ToProto

func (e SessionStateType) ToProto() E

func (*SessionStateType) UnmarshalJSON added in v0.3.0

func (e *SessionStateType) UnmarshalJSON(b []byte) (err error)

type SessionTraits added in v0.3.0

type SessionTraits struct{}

func (SessionTraits) StrictValidate added in v0.3.0

func (SessionTraits) StrictValidate(m *SessionPB) error

func (SessionTraits) Validate added in v0.3.0

func (SessionTraits) Validate(m *SessionPB) error

type SetValue

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

func (SetValue) Equal added in v0.3.0

func (o SetValue) Equal(other interface{ ToProto() M }) bool

func (SetValue) Hash added in v0.3.0

func (o SetValue) Hash() string

func (SetValue) IsValid added in v0.3.0

func (o SetValue) IsValid() bool

func (SetValue) MarshalJSON added in v0.3.0

func (o SetValue) MarshalJSON() ([]byte, error)

func (SetValue) Message added in v0.3.0

func (o SetValue) Message() proto.Message

func (SetValue) Strict added in v0.3.0

func (o SetValue) Strict() error

func (SetValue) String added in v0.3.0

func (o SetValue) String() string

func (SetValue) ToProto added in v0.3.0

func (o SetValue) ToProto() M

func (*SetValue) UnmarshalJSON added in v0.3.0

func (o *SetValue) UnmarshalJSON(b []byte) (err error)

func (SetValue) Values added in v0.3.0

func (l SetValue) Values() []Value

type SetValuePB added in v0.3.0

type SetValuePB = valuev1.Set

type Status added in v0.5.13

type Status struct {
	// contains filtered or unexported fields
}
var InvalidStatus Status

func NewStatus added in v0.5.13

func NewStatus(code StatusCode, msg string) Status

func StatusFromProto added in v0.5.13

func StatusFromProto(m *StatusPB) (Status, error)

func StrictStatusFromProto added in v0.5.13

func StrictStatusFromProto(m *StatusPB) (Status, error)

func (Status) Code added in v0.5.13

func (p Status) Code() StatusCode

func (Status) Equal added in v0.5.13

func (o Status) Equal(other interface{ ToProto() M }) bool

func (Status) Hash added in v0.5.13

func (o Status) Hash() string

func (Status) IsValid added in v0.5.13

func (o Status) IsValid() bool

func (Status) MarshalJSON added in v0.5.13

func (o Status) MarshalJSON() ([]byte, error)

func (Status) Message added in v0.5.13

func (p Status) Message() string

func (Status) Strict added in v0.5.13

func (o Status) Strict() error

func (Status) String added in v0.5.13

func (o Status) String() string

func (Status) ToProto added in v0.5.13

func (o Status) ToProto() M

func (*Status) UnmarshalJSON added in v0.5.13

func (o *Status) UnmarshalJSON(b []byte) (err error)

func (Status) WithState added in v0.5.13

func (p Status) WithState(s StatusCode) Status

type StatusCode added in v0.5.13

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

func ParseStatusCode added in v0.5.13

func ParseStatusCode(raw string) (StatusCode, error)

func StatusCodeFromProto added in v0.5.13

func StatusCodeFromProto(e commonv1.Status_Code) (StatusCode, error)

func (StatusCode) IsZero added in v0.5.13

func (e StatusCode) IsZero() bool

func (StatusCode) MarshalJSON added in v0.5.13

func (e StatusCode) MarshalJSON() ([]byte, error)

func (StatusCode) Prefix added in v0.5.13

func (e StatusCode) Prefix() string

func (StatusCode) Strict added in v0.5.13

func (e StatusCode) Strict() error

func (StatusCode) String added in v0.5.13

func (e StatusCode) String() string

func (StatusCode) ToProto added in v0.5.13

func (e StatusCode) ToProto() E

func (*StatusCode) UnmarshalJSON added in v0.5.13

func (e *StatusCode) UnmarshalJSON(b []byte) (err error)

type StatusPB added in v0.5.13

type StatusPB = commonv1.Status

type StatusTraits added in v0.5.13

type StatusTraits struct{}

func (StatusTraits) StrictValidate added in v0.5.13

func (StatusTraits) StrictValidate(m *StatusPB) error

func (StatusTraits) Validate added in v0.5.13

func (StatusTraits) Validate(m *StatusPB) error

type StringValue

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

func (StringValue) Equal added in v0.3.0

func (o StringValue) Equal(other interface{ ToProto() M }) bool

func (StringValue) Hash added in v0.3.0

func (o StringValue) Hash() string

func (StringValue) IsValid added in v0.3.0

func (o StringValue) IsValid() bool

func (StringValue) MarshalJSON added in v0.3.0

func (o StringValue) MarshalJSON() ([]byte, error)

func (StringValue) Message added in v0.3.0

func (o StringValue) Message() proto.Message

func (StringValue) Strict added in v0.3.0

func (o StringValue) Strict() error

func (StringValue) String added in v0.3.0

func (o StringValue) String() string

func (StringValue) ToProto added in v0.3.0

func (o StringValue) ToProto() M

func (*StringValue) UnmarshalJSON added in v0.3.0

func (o *StringValue) UnmarshalJSON(b []byte) (err error)

func (StringValue) Value added in v0.3.0

func (s StringValue) Value() string

type StringValuePB added in v0.3.0

type StringValuePB = valuev1.String

type StructValue

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

func (StructValue) Ctor added in v0.3.0

func (s StructValue) Ctor() Value

func (StructValue) Equal added in v0.3.0

func (o StructValue) Equal(other interface{ ToProto() M }) bool

func (StructValue) Fields added in v0.3.0

func (s StructValue) Fields() map[string]Value

func (StructValue) Hash added in v0.3.0

func (o StructValue) Hash() string

func (StructValue) IsValid added in v0.3.0

func (o StructValue) IsValid() bool

func (StructValue) MarshalJSON added in v0.3.0

func (o StructValue) MarshalJSON() ([]byte, error)

func (StructValue) Message added in v0.3.0

func (o StructValue) Message() proto.Message

func (StructValue) Strict added in v0.3.0

func (o StructValue) Strict() error

func (StructValue) String added in v0.3.0

func (o StructValue) String() string

func (StructValue) ToProto added in v0.3.0

func (o StructValue) ToProto() M

func (*StructValue) UnmarshalJSON added in v0.3.0

func (o *StructValue) UnmarshalJSON(b []byte) (err error)

type StructValuePB added in v0.3.0

type StructValuePB = valuev1.Struct

type Symbol

type Symbol struct {
	// contains filtered or unexported fields
}
var InvalidSymbol Symbol

func NewRandomSymbol added in v0.3.0

func NewRandomSymbol() Symbol

func NewSymbol added in v0.5.0

func NewSymbol(s string) Symbol

Helper function to easily create new symbols. Will panic if given string is invalid.

func NewSymbols added in v0.5.0

func NewSymbols(s ...string) []Symbol

func ParseSymbol

func ParseSymbol(s string) (Symbol, error)

func StrictParseSymbol

func StrictParseSymbol(s string) (Symbol, error)

func (Symbol) Hash added in v0.3.0

func (s Symbol) Hash() string

func (Symbol) IsValid added in v0.3.0

func (s Symbol) IsValid() bool

func (Symbol) MarshalJSON added in v0.3.0

func (s Symbol) MarshalJSON() ([]byte, error)

func (Symbol) Strict added in v0.3.0

func (s Symbol) Strict() error

func (Symbol) String added in v0.3.0

func (s Symbol) String() string

func (*Symbol) UnmarshalJSON added in v0.3.0

func (s *Symbol) UnmarshalJSON(data []byte) error

type SymbolValue

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

func (SymbolValue) Equal added in v0.3.0

func (o SymbolValue) Equal(other interface{ ToProto() M }) bool

func (SymbolValue) Hash added in v0.3.0

func (o SymbolValue) Hash() string

func (SymbolValue) IsValid added in v0.3.0

func (o SymbolValue) IsValid() bool

func (SymbolValue) MarshalJSON added in v0.3.0

func (o SymbolValue) MarshalJSON() ([]byte, error)

func (SymbolValue) Message added in v0.3.0

func (o SymbolValue) Message() proto.Message

func (SymbolValue) Strict added in v0.3.0

func (o SymbolValue) Strict() error

func (SymbolValue) String added in v0.3.0

func (o SymbolValue) String() string

func (SymbolValue) Symbol added in v0.3.0

func (s SymbolValue) Symbol() Symbol

func (SymbolValue) ToProto added in v0.3.0

func (o SymbolValue) ToProto() M

func (*SymbolValue) UnmarshalJSON added in v0.3.0

func (o *SymbolValue) UnmarshalJSON(b []byte) (err error)

type SymbolValuePB added in v0.3.0

type SymbolValuePB = valuev1.Symbol

type TimeValue

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

func (TimeValue) Equal added in v0.3.0

func (o TimeValue) Equal(other interface{ ToProto() M }) bool

func (TimeValue) Hash added in v0.3.0

func (o TimeValue) Hash() string

func (TimeValue) IsValid added in v0.3.0

func (o TimeValue) IsValid() bool

func (TimeValue) MarshalJSON added in v0.3.0

func (o TimeValue) MarshalJSON() ([]byte, error)

func (TimeValue) Message added in v0.3.0

func (o TimeValue) Message() proto.Message

func (TimeValue) Strict added in v0.3.0

func (o TimeValue) Strict() error

func (TimeValue) String added in v0.3.0

func (o TimeValue) String() string

func (TimeValue) ToProto added in v0.3.0

func (o TimeValue) ToProto() M

func (*TimeValue) UnmarshalJSON added in v0.3.0

func (o *TimeValue) UnmarshalJSON(b []byte) (err error)

func (TimeValue) Value added in v0.3.0

func (s TimeValue) Value() time.Time

type TimeValuePB added in v0.3.0

type TimeValuePB = valuev1.Time

type Trigger added in v0.2.0

type Trigger struct {
	// contains filtered or unexported fields
}
var InvalidTrigger Trigger

func StrictTriggerFromProto added in v0.2.0

func StrictTriggerFromProto(m *TriggerPB) (Trigger, error)

func TriggerFromProto added in v0.2.0

func TriggerFromProto(m *TriggerPB) (Trigger, error)

func (Trigger) CodeLocation added in v0.3.0

func (p Trigger) CodeLocation() CodeLocation

func (Trigger) ConnectionID added in v0.3.0

func (p Trigger) ConnectionID() ConnectionID

func (Trigger) Data added in v0.4.0

func (p Trigger) Data() map[string]Value

func (Trigger) EnvID added in v0.3.0

func (p Trigger) EnvID() EnvID

func (Trigger) Equal added in v0.3.0

func (o Trigger) Equal(other interface{ ToProto() M }) bool

func (Trigger) EventType added in v0.3.0

func (p Trigger) EventType() string

func (Trigger) Filter added in v0.4.0

func (p Trigger) Filter() string

func (Trigger) Hash added in v0.3.0

func (o Trigger) Hash() string

func (Trigger) ID added in v0.3.0

func (p Trigger) ID() TriggerID

func (Trigger) IsValid added in v0.3.0

func (o Trigger) IsValid() bool

func (Trigger) MarshalJSON added in v0.3.0

func (o Trigger) MarshalJSON() ([]byte, error)

func (Trigger) Message added in v0.3.0

func (o Trigger) Message() proto.Message

func (Trigger) Name added in v0.4.0

func (p Trigger) Name() Symbol

func (Trigger) Strict added in v0.3.0

func (o Trigger) Strict() error

func (Trigger) String added in v0.3.0

func (o Trigger) String() string

func (Trigger) ToProto added in v0.3.0

func (o Trigger) ToProto() M

func (Trigger) ToValues added in v0.4.0

func (p Trigger) ToValues() map[string]Value

func (*Trigger) UnmarshalJSON added in v0.3.0

func (o *Trigger) UnmarshalJSON(b []byte) (err error)

func (Trigger) WithAdditionalData added in v0.6.4

func (p Trigger) WithAdditionalData(key string, val Value) Trigger

func (Trigger) WithConnectionID added in v0.3.0

func (p Trigger) WithConnectionID(id ConnectionID) Trigger

func (Trigger) WithEnvID added in v0.3.0

func (p Trigger) WithEnvID(id EnvID) Trigger

func (Trigger) WithFilter added in v0.4.0

func (p Trigger) WithFilter(f string) Trigger

func (Trigger) WithID added in v0.3.0

func (p Trigger) WithID(id TriggerID) Trigger

func (Trigger) WithName added in v0.4.0

func (p Trigger) WithName(s Symbol) Trigger

func (Trigger) WithNewID added in v0.3.0

func (p Trigger) WithNewID() Trigger

type TriggerID added in v0.2.0

type TriggerID = id[triggerIDTraits]
var InvalidTriggerID TriggerID

func NewTriggerID added in v0.2.0

func NewTriggerID() TriggerID

func ParseTriggerID added in v0.2.0

func ParseTriggerID(s string) (TriggerID, error)

func StrictParseTriggerID added in v0.2.0

func StrictParseTriggerID(s string) (TriggerID, error)

type TriggerPB added in v0.2.0

type TriggerPB = triggerv1.Trigger

type TriggerTraits added in v0.3.0

type TriggerTraits struct{}

func (TriggerTraits) StrictValidate added in v0.3.0

func (TriggerTraits) StrictValidate(m *TriggerPB) error

func (TriggerTraits) Validate added in v0.3.0

func (TriggerTraits) Validate(m *TriggerPB) error

type UUID added in v0.3.0

type UUID = uuid.UUID

func UUIDGenerator

func UUIDGenerator() UUID

type User added in v0.5.0

type User struct {
	// contains filtered or unexported fields
}
var InvalidUser User

func NewUser added in v0.5.0

func NewUser(provider string, data map[string]string) User

func UserFromProto added in v0.5.0

func UserFromProto(m *UserPB) (User, error)

func (User) Data added in v0.5.0

func (u User) Data() map[string]string

func (User) Equal added in v0.5.0

func (o User) Equal(other interface{ ToProto() M }) bool

func (User) Hash added in v0.5.0

func (o User) Hash() string

func (User) IsValid added in v0.5.0

func (o User) IsValid() bool

func (User) Login added in v0.5.3

func (u User) Login() string

func (User) MarshalJSON added in v0.5.0

func (o User) MarshalJSON() ([]byte, error)

func (User) Message added in v0.5.0

func (o User) Message() proto.Message

func (User) Provider added in v0.5.0

func (u User) Provider() string

func (User) Strict added in v0.5.0

func (o User) Strict() error

func (User) String added in v0.5.0

func (o User) String() string

func (User) Title added in v0.5.0

func (u User) Title() (id string)

Used for display only.

func (User) ToProto added in v0.5.0

func (o User) ToProto() M

func (*User) UnmarshalJSON added in v0.5.0

func (o *User) UnmarshalJSON(b []byte) (err error)

type UserPB added in v0.5.0

type UserPB = userv1.User

type UserTraits added in v0.5.0

type UserTraits struct{}

func (UserTraits) StrictValidate added in v0.5.0

func (UserTraits) StrictValidate(m *UserPB) error

func (UserTraits) Validate added in v0.5.0

func (UserTraits) Validate(m *UserPB) error

type Value

type Value struct {
	// contains filtered or unexported fields
}
var InvalidValue Value

func NewBooleanValue

func NewBooleanValue(v bool) Value

func NewBytesValue

func NewBytesValue(v []byte) Value

func NewConstFunctionError added in v0.4.0

func NewConstFunctionError(name string, in error) (Value, error)

func NewConstFunctionValue added in v0.4.0

func NewConstFunctionValue(name string, data Value) (Value, error)

func NewDictValue

func NewDictValue(items []DictItem) (Value, error)

func NewDictValueFromStringMap

func NewDictValueFromStringMap(m map[string]Value) Value

func NewDurationValue

func NewDurationValue(v time.Duration) Value

func NewFloatValue

func NewFloatValue[T constraints.Float](v T) Value

func NewFunctionValue

func NewFunctionValue(xid ExecutorID, name string, data []byte, flags []FunctionFlag, desc ModuleFunction) (Value, error)

func NewIntegerValue

func NewIntegerValue[T constraints.Integer](v T) Value

func NewListValue

func NewListValue(vs []Value) (Value, error)

func NewModuleValue

func NewModuleValue(name Symbol, fields map[string]Value) (Value, error)

func NewSetValue

func NewSetValue(vs []Value) (Value, error)

func NewStringValue

func NewStringValue(s string) Value

func NewStructValue

func NewStructValue(ctor Value, fields map[string]Value) (Value, error)

func NewSymbolValue

func NewSymbolValue(s Symbol) Value

func NewTimeValue

func NewTimeValue(v time.Time) Value

func NewValue

func NewValue(cv concreteValue) Value

func StrictValueFromProto

func StrictValueFromProto(m *ValuePB) (Value, error)

func ValueFromProto

func ValueFromProto(m *ValuePB) (Value, error)

func WrapValue added in v0.3.0

func WrapValue[T any](v T) (Value, error)

func (Value) Concrete added in v0.3.0

func (v Value) Concrete() concreteValue

func (Value) Equal added in v0.3.0

func (o Value) Equal(other interface{ ToProto() M }) bool

func (Value) GetBoolean added in v0.3.0

func (v Value) GetBoolean() BooleanValue

func (Value) GetBytes added in v0.3.0

func (v Value) GetBytes() BytesValue

func (Value) GetDict added in v0.3.0

func (v Value) GetDict() DictValue

func (Value) GetDuration added in v0.3.0

func (v Value) GetDuration() DurationValue

func (Value) GetFloat added in v0.3.0

func (v Value) GetFloat() FloatValue

func (Value) GetFunction added in v0.3.0

func (v Value) GetFunction() FunctionValue

func (Value) GetInteger added in v0.3.0

func (v Value) GetInteger() IntegerValue

func (Value) GetList added in v0.3.0

func (v Value) GetList() ListValue

func (Value) GetModule added in v0.3.0

func (v Value) GetModule() ModuleValue

func (Value) GetNothing added in v0.3.0

func (v Value) GetNothing() NothingValue

func (Value) GetSet added in v0.3.0

func (v Value) GetSet() SetValue

func (Value) GetString added in v0.3.0

func (v Value) GetString() StringValue

func (Value) GetStruct added in v0.3.0

func (v Value) GetStruct() StructValue

func (Value) GetSymbol added in v0.3.0

func (v Value) GetSymbol() SymbolValue

func (Value) GetTime added in v0.3.0

func (v Value) GetTime() TimeValue

func (Value) Hash added in v0.3.0

func (o Value) Hash() string

func (Value) IsBoolean added in v0.3.0

func (v Value) IsBoolean() bool

func (Value) IsBytes added in v0.3.0

func (v Value) IsBytes() bool

func (Value) IsDict added in v0.3.0

func (v Value) IsDict() bool

func (Value) IsDuration added in v0.3.0

func (v Value) IsDuration() bool

func (Value) IsFloat added in v0.3.0

func (v Value) IsFloat() bool

func (Value) IsFunction added in v0.3.0

func (v Value) IsFunction() bool

func (Value) IsInteger added in v0.3.0

func (v Value) IsInteger() bool

func (Value) IsList added in v0.3.0

func (v Value) IsList() bool

func (Value) IsModule added in v0.3.0

func (v Value) IsModule() bool

func (Value) IsNothing added in v0.3.0

func (v Value) IsNothing() bool

func (Value) IsSet added in v0.3.0

func (v Value) IsSet() bool

func (Value) IsString added in v0.3.0

func (v Value) IsString() bool

func (Value) IsStruct added in v0.3.0

func (v Value) IsStruct() bool

func (Value) IsSymbol added in v0.3.0

func (v Value) IsSymbol() bool

func (Value) IsTime added in v0.3.0

func (v Value) IsTime() bool

func (Value) IsValid added in v0.3.0

func (o Value) IsValid() bool

func (Value) MarshalJSON added in v0.3.0

func (o Value) MarshalJSON() ([]byte, error)

func (Value) Message added in v0.3.0

func (o Value) Message() proto.Message

func (Value) Strict added in v0.3.0

func (o Value) Strict() error

func (Value) String added in v0.3.0

func (o Value) String() string

func (Value) ToDuration added in v0.3.0

func (v Value) ToDuration() (time.Duration, error)

func (Value) ToProto added in v0.3.0

func (o Value) ToProto() M

func (Value) ToString added in v0.3.0

func (v Value) ToString() (string, error)

func (Value) ToStringValuesMap added in v0.3.0

func (v Value) ToStringValuesMap() (map[string]Value, error)

func (Value) ToTime added in v0.3.0

func (v Value) ToTime() (time.Time, error)

func (*Value) UnmarshalJSON added in v0.3.0

func (o *Value) UnmarshalJSON(b []byte) (err error)

func (Value) Unwrap added in v0.3.0

func (v Value) Unwrap() (any, error)

func (Value) UnwrapInto added in v0.3.2

func (v Value) UnwrapInto(dst any) error

type ValuePB

type ValuePB = valuev1.Value

type ValueTraits added in v0.3.0

type ValueTraits struct{}

func (ValueTraits) StrictValidate added in v0.3.0

func (ValueTraits) StrictValidate(m *ValuePB) error

func (ValueTraits) Validate added in v0.3.0

func (ValueTraits) Validate(m *ValuePB) error

type ValueWrapper added in v0.3.0

type ValueWrapper struct {
	// Wrap structs as maps.
	WrapStructAsMap bool

	// Unwrap: Treat all dict keys as strings (JSON does not deal well with map[any]any).
	// TODO: maybe allow ints, floats, any hashable as well somehow.
	SafeForJSON bool

	// Wrap: Used for functions that are wrapped using this wrapper.
	ExecutorID ExecutorID

	FromStructFieldNameCaser func(string) string
	ToStructFieldNameCaser   func(string) string

	// Unwrap: if a struct, marshal it to JSON directly, do not convert to map.
	UnwrapStructsAsJSON bool

	// Error out when trying to unwrap into a struct and the struct has fields that do not exist in the value.
	UnwrapErrorOnNonexistentStructFields bool

	// Wrap: if true, wrap a reader as a string instead of bytes.
	WrapReaderAsString bool

	// Ignore readers when wrapping and unwrapping.
	IgnoreReader bool

	// Ignore functions.
	IgnoreFunctions bool

	// Unwrap: transform duration into microseconds, do not convert to string.
	RawDuration bool

	// Unwrap: Tranform value before unwrapping. If returns InvalidValue, ignore value.
	Preunwrap func(Value) (Value, error)

	// Wrap: Transform value before wrapping.
	Prewrap func(any) (any, error)

	// Unwrap: if not handled, use this unwrapper.
	UnwrapUnknown func(Value) (any, error)
}

CAVEATS: - All integers are treated as int64. - All floats are treated as float64. - json.Number is converted to either int64 or float64, depends on its value. If neither matches, as a string. - json.RawMessage is un/marshalled directly into/from Value. - functions that are wrapped by a specific wrapper can be unwrapped only with that specific wrapper instance.

var DefaultValueWrapper ValueWrapper

func (ValueWrapper) Unwrap added in v0.3.0

func (w ValueWrapper) Unwrap(v Value) (any, error)

Unwraps a value, converting it to a native go type.

func (ValueWrapper) UnwrapInto added in v0.3.0

func (w ValueWrapper) UnwrapInto(dst any, v Value) error

func (ValueWrapper) UnwrapMap added in v0.6.0

func (w ValueWrapper) UnwrapMap(m map[string]Value) (map[string]any, error)

func (ValueWrapper) Wrap added in v0.3.0

func (w ValueWrapper) Wrap(v any) (Value, error)

Wraps a native go type in a Value.

type Var added in v0.5.0

type Var struct {
	// contains filtered or unexported fields
}
var InvalidVar Var

func NewVar added in v0.5.0

func NewVar(n Symbol, v string, isSecret bool) Var

func StrictVarFromProto added in v0.5.0

func StrictVarFromProto(m *VarPB) (Var, error)

func VarFromProto added in v0.5.0

func VarFromProto(m *VarPB) (Var, error)

func (Var) Equal added in v0.5.0

func (o Var) Equal(other interface{ ToProto() M }) bool

func (Var) Hash added in v0.5.0

func (o Var) Hash() string

func (Var) IsSecret added in v0.5.0

func (p Var) IsSecret() bool

func (Var) IsValid added in v0.5.0

func (o Var) IsValid() bool

func (Var) MarshalJSON added in v0.5.0

func (o Var) MarshalJSON() ([]byte, error)

func (Var) Message added in v0.5.0

func (o Var) Message() proto.Message

func (Var) Name added in v0.5.0

func (p Var) Name() Symbol

func (Var) ScopeID added in v0.5.0

func (p Var) ScopeID() VarScopeID

func (Var) Strict added in v0.5.0

func (o Var) Strict() error

func (Var) String added in v0.5.0

func (o Var) String() string

func (Var) ToProto added in v0.5.0

func (o Var) ToProto() M

func (*Var) UnmarshalJSON added in v0.5.0

func (o *Var) UnmarshalJSON(b []byte) (err error)

func (Var) Value added in v0.5.0

func (p Var) Value() string

func (Var) WithScopeID added in v0.5.0

func (p Var) WithScopeID(id VarScopeID) Var

type VarPB added in v0.5.0

type VarPB = varsv1.Var

type VarScopeID added in v0.5.0

type VarScopeID struct {
	// contains filtered or unexported fields
}
var InvalidVarScopeID VarScopeID

func NewVarScopeID added in v0.5.0

func NewVarScopeID[T concreteVarScopeID](in T) VarScopeID

func ParseVarScopeID added in v0.5.0

func ParseVarScopeID(s string) (VarScopeID, error)

func (VarScopeID) AsID added in v0.5.0

func (e VarScopeID) AsID() ID

func (VarScopeID) Hash added in v0.5.0

func (i VarScopeID) Hash() string

func (VarScopeID) IsConnectionID added in v0.5.0

func (e VarScopeID) IsConnectionID() bool

func (VarScopeID) IsEnvID added in v0.5.0

func (e VarScopeID) IsEnvID() bool

func (VarScopeID) IsValid added in v0.5.0

func (i VarScopeID) IsValid() bool

func (VarScopeID) Kind added in v0.5.0

func (i VarScopeID) Kind() string

func (VarScopeID) MarshalJSON added in v0.5.0

func (i VarScopeID) MarshalJSON() ([]byte, error)

func (VarScopeID) Strict added in v0.5.0

func (i VarScopeID) Strict() error

func (VarScopeID) String added in v0.5.0

func (i VarScopeID) String() string

func (VarScopeID) ToConnectionID added in v0.5.0

func (e VarScopeID) ToConnectionID() ConnectionID

func (VarScopeID) ToEnvID added in v0.5.0

func (e VarScopeID) ToEnvID() EnvID

func (VarScopeID) UUIDValue added in v0.5.0

func (i VarScopeID) UUIDValue() UUID

func (*VarScopeID) UnmarshalJSON added in v0.5.0

func (i *VarScopeID) UnmarshalJSON(data []byte) (err error)

func (VarScopeID) Value added in v0.5.0

func (i VarScopeID) Value() *UUID

type VarTraits added in v0.5.0

type VarTraits struct{}

func (VarTraits) StrictValidate added in v0.5.0

func (VarTraits) StrictValidate(m *VarPB) error

func (VarTraits) Validate added in v0.5.0

func (VarTraits) Validate(m *VarPB) error

type Vars added in v0.5.0

type Vars []Var

func EncodeVars added in v0.5.0

func EncodeVars(in any) (vs Vars)

Encodes `in` into Vars. `in` must be a struct or a non-nil pointer to a struct. All members must be strings. A field tag of `var:"secret"` will make the field secret.

func NewVars added in v0.5.0

func NewVars(vs ...Var) Vars

func (Vars) Append added in v0.5.0

func (vs Vars) Append(others ...Var) Vars

func (Vars) Decode added in v0.5.0

func (vs Vars) Decode(out any)

Decode Vars into `out`. `out` must be a non-nil pointer to a struct.

func (Vars) Encode added in v0.5.0

func (vs Vars) Encode(x any) Vars

func (Vars) Get added in v0.5.0

func (vs Vars) Get(name Symbol) Var

func (Vars) GetByString added in v0.5.0

func (vs Vars) GetByString(name string) Var

func (Vars) GetValue added in v0.5.0

func (vs Vars) GetValue(name Symbol) string

func (Vars) GetValueByString added in v0.5.0

func (vs Vars) GetValueByString(name string) string

func (Vars) Has added in v0.5.0

func (vs Vars) Has(name Symbol) bool

func (Vars) Set added in v0.5.0

func (vs Vars) Set(n Symbol, v string, isSecret bool) Vars

panics if n is an invalid var name.

func (Vars) ToMap added in v0.5.0

func (vs Vars) ToMap() map[Symbol]Var

func (Vars) ToStringMap added in v0.5.0

func (vs Vars) ToStringMap() map[string]string

func (Vars) WithPrefix added in v0.5.0

func (vs Vars) WithPrefix(prefix string) Vars

Jump to

Keyboard shortcuts

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