effectusv1

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RulesetExecutionService_ExecuteRuleset_FullMethodName    = "/effectus.v1.RulesetExecutionService/ExecuteRuleset"
	RulesetExecutionService_GetRulesetInfo_FullMethodName    = "/effectus.v1.RulesetExecutionService/GetRulesetInfo"
	RulesetExecutionService_ListRulesets_FullMethodName      = "/effectus.v1.RulesetExecutionService/ListRulesets"
	RulesetExecutionService_RegisterRuleset_FullMethodName   = "/effectus.v1.RulesetExecutionService/RegisterRuleset"
	RulesetExecutionService_UnregisterRuleset_FullMethodName = "/effectus.v1.RulesetExecutionService/UnregisterRuleset"
	RulesetExecutionService_StreamExecution_FullMethodName   = "/effectus.v1.RulesetExecutionService/StreamExecution"
	RulesetExecutionService_ValidateSchema_FullMethodName    = "/effectus.v1.RulesetExecutionService/ValidateSchema"
	RulesetExecutionService_GetSchemaVersion_FullMethodName  = "/effectus.v1.RulesetExecutionService/GetSchemaVersion"
)
View Source 
const (
	FactRegistryService_RegisterFactSchema_FullMethodName = "/effectus.v1.FactRegistryService/RegisterFactSchema"
	FactRegistryService_GetFactSchema_FullMethodName      = "/effectus.v1.FactRegistryService/GetFactSchema"
	FactRegistryService_ListFactSchemas_FullMethodName    = "/effectus.v1.FactRegistryService/ListFactSchemas"
	FactRegistryService_ValidateFactData_FullMethodName   = "/effectus.v1.FactRegistryService/ValidateFactData"
	FactRegistryService_CheckCompatibility_FullMethodName = "/effectus.v1.FactRegistryService/CheckCompatibility"
)
View Source 
const (
	VerbRegistryService_RegisterVerbInterface_FullMethodName       = "/effectus.v1.VerbRegistryService/RegisterVerbInterface"
	VerbRegistryService_GetVerbInterface_FullMethodName            = "/effectus.v1.VerbRegistryService/GetVerbInterface"
	VerbRegistryService_ListVerbInterfaces_FullMethodName          = "/effectus.v1.VerbRegistryService/ListVerbInterfaces"
	VerbRegistryService_ValidateVerbCall_FullMethodName            = "/effectus.v1.VerbRegistryService/ValidateVerbCall"
	VerbRegistryService_CheckInterfaceCompatibility_FullMethodName = "/effectus.v1.VerbRegistryService/CheckInterfaceCompatibility"
	VerbRegistryService_GenerateVerbCode_FullMethodName            = "/effectus.v1.VerbRegistryService/GenerateVerbCode"
)

Variables

View Source 
var (
	FieldType_name = map[int32]string{
		0:  "FIELD_TYPE_UNSPECIFIED",
		1:  "FIELD_TYPE_DOUBLE",
		2:  "FIELD_TYPE_FLOAT",
		3:  "FIELD_TYPE_INT64",
		4:  "FIELD_TYPE_UINT64",
		5:  "FIELD_TYPE_INT32",
		6:  "FIELD_TYPE_FIXED64",
		7:  "FIELD_TYPE_FIXED32",
		8:  "FIELD_TYPE_BOOL",
		9:  "FIELD_TYPE_STRING",
		10: "FIELD_TYPE_GROUP",
		11: "FIELD_TYPE_MESSAGE",
		12: "FIELD_TYPE_BYTES",
		13: "FIELD_TYPE_UINT32",
		14: "FIELD_TYPE_ENUM",
		15: "FIELD_TYPE_SFIXED32",
		16: "FIELD_TYPE_SFIXED64",
		17: "FIELD_TYPE_SINT32",
		18: "FIELD_TYPE_SINT64",
	}
	FieldType_value = map[string]int32{
		"FIELD_TYPE_UNSPECIFIED": 0,
		"FIELD_TYPE_DOUBLE":      1,
		"FIELD_TYPE_FLOAT":       2,
		"FIELD_TYPE_INT64":       3,
		"FIELD_TYPE_UINT64":      4,
		"FIELD_TYPE_INT32":       5,
		"FIELD_TYPE_FIXED64":     6,
		"FIELD_TYPE_FIXED32":     7,
		"FIELD_TYPE_BOOL":        8,
		"FIELD_TYPE_STRING":      9,
		"FIELD_TYPE_GROUP":       10,
		"FIELD_TYPE_MESSAGE":     11,
		"FIELD_TYPE_BYTES":       12,
		"FIELD_TYPE_UINT32":      13,
		"FIELD_TYPE_ENUM":        14,
		"FIELD_TYPE_SFIXED32":    15,
		"FIELD_TYPE_SFIXED64":    16,
		"FIELD_TYPE_SINT32":      17,
		"FIELD_TYPE_SINT64":      18,
	}
)

Enum value maps for FieldType.

View Source 
var (
	ExecutionWaitMode_name = map[int32]string{
		0: "EXECUTION_WAIT_MODE_UNSPECIFIED",
		1: "EXECUTION_WAIT_MODE_ACCEPTED",
		2: "EXECUTION_WAIT_MODE_TERMINAL",
	}
	ExecutionWaitMode_value = map[string]int32{
		"EXECUTION_WAIT_MODE_UNSPECIFIED": 0,
		"EXECUTION_WAIT_MODE_ACCEPTED":    1,
		"EXECUTION_WAIT_MODE_TERMINAL":    2,
	}
)

Enum value maps for ExecutionWaitMode.

View Source 
var (
	EffectStatus_name = map[int32]string{
		0: "EFFECT_STATUS_UNSPECIFIED",
		1: "EFFECT_STATUS_PENDING",
		2: "EFFECT_STATUS_EXECUTED",
		3: "EFFECT_STATUS_FAILED",
		4: "EFFECT_STATUS_SKIPPED",
		5: "EFFECT_STATUS_RETRYING",
		6: "EFFECT_STATUS_COMPENSATING",
	}
	EffectStatus_value = map[string]int32{
		"EFFECT_STATUS_UNSPECIFIED":  0,
		"EFFECT_STATUS_PENDING":      1,
		"EFFECT_STATUS_EXECUTED":     2,
		"EFFECT_STATUS_FAILED":       3,
		"EFFECT_STATUS_SKIPPED":      4,
		"EFFECT_STATUS_RETRYING":     5,
		"EFFECT_STATUS_COMPENSATING": 6,
	}
)

Enum value maps for EffectStatus.

View Source 
var (
	RuleType_name = map[int32]string{
		0: "RULE_TYPE_UNSPECIFIED",
		1: "RULE_TYPE_LIST",
		2: "RULE_TYPE_FLOW",
	}
	RuleType_value = map[string]int32{
		"RULE_TYPE_UNSPECIFIED": 0,
		"RULE_TYPE_LIST":        1,
		"RULE_TYPE_FLOW":        2,
	}
)

Enum value maps for RuleType.

View Source 
var (
	ExecutionPhase_name = map[int32]string{
		0: "EXECUTION_PHASE_UNSPECIFIED",
		1: "EXECUTION_PHASE_VALIDATION",
		2: "EXECUTION_PHASE_SCHEMA_CHECK",
		3: "EXECUTION_PHASE_COMPILATION",
		4: "EXECUTION_PHASE_EXECUTION",
		5: "EXECUTION_PHASE_COMPLETION",
		6: "EXECUTION_PHASE_ERROR",
	}
	ExecutionPhase_value = map[string]int32{
		"EXECUTION_PHASE_UNSPECIFIED":  0,
		"EXECUTION_PHASE_VALIDATION":   1,
		"EXECUTION_PHASE_SCHEMA_CHECK": 2,
		"EXECUTION_PHASE_COMPILATION":  3,
		"EXECUTION_PHASE_EXECUTION":    4,
		"EXECUTION_PHASE_COMPLETION":   5,
		"EXECUTION_PHASE_ERROR":        6,
	}
)

Enum value maps for ExecutionPhase.

View Source 
var (
	SourceDialect_name = map[int32]string{
		0: "SOURCE_DIALECT_UNSPECIFIED",
		1: "SOURCE_DIALECT_LIST",
		2: "SOURCE_DIALECT_FLOW",
	}
	SourceDialect_value = map[string]int32{
		"SOURCE_DIALECT_UNSPECIFIED": 0,
		"SOURCE_DIALECT_LIST":        1,
		"SOURCE_DIALECT_FLOW":        2,
	}
)

Enum value maps for SourceDialect.

View Source 
var (
	ExecutionPolicy_name = map[int32]string{
		0: "EXECUTION_POLICY_UNSPECIFIED",
		1: "EXECUTION_POLICY_DURABLE_FAIL_FAST",
		2: "EXECUTION_POLICY_DURABLE_COMPENSATING",
	}
	ExecutionPolicy_value = map[string]int32{
		"EXECUTION_POLICY_UNSPECIFIED":          0,
		"EXECUTION_POLICY_DURABLE_FAIL_FAST":    1,
		"EXECUTION_POLICY_DURABLE_COMPENSATING": 2,
	}
)

Enum value maps for ExecutionPolicy.

View Source 
var (
	UnaryOperator_name = map[int32]string{
		0: "UNARY_OPERATOR_UNSPECIFIED",
		1: "UNARY_OPERATOR_NOT",
		2: "UNARY_OPERATOR_NEGATE",
	}
	UnaryOperator_value = map[string]int32{
		"UNARY_OPERATOR_UNSPECIFIED": 0,
		"UNARY_OPERATOR_NOT":         1,
		"UNARY_OPERATOR_NEGATE":      2,
	}
)

Enum value maps for UnaryOperator.

View Source 
var (
	BinaryOperator_name = map[int32]string{
		0:  "BINARY_OPERATOR_UNSPECIFIED",
		1:  "BINARY_OPERATOR_EQUAL",
		2:  "BINARY_OPERATOR_NOT_EQUAL",
		3:  "BINARY_OPERATOR_GREATER",
		4:  "BINARY_OPERATOR_GREATER_EQUAL",
		5:  "BINARY_OPERATOR_LESS",
		6:  "BINARY_OPERATOR_LESS_EQUAL",
		7:  "BINARY_OPERATOR_AND",
		8:  "BINARY_OPERATOR_OR",
		9:  "BINARY_OPERATOR_IN",
		10: "BINARY_OPERATOR_CONTAINS",
		11: "BINARY_OPERATOR_ADD",
		12: "BINARY_OPERATOR_SUBTRACT",
		13: "BINARY_OPERATOR_MULTIPLY",
		14: "BINARY_OPERATOR_DIVIDE",
		15: "BINARY_OPERATOR_MODULO",
		16: "BINARY_OPERATOR_MATCHES",
		17: "BINARY_OPERATOR_STARTS_WITH",
		18: "BINARY_OPERATOR_ENDS_WITH",
	}
	BinaryOperator_value = map[string]int32{
		"BINARY_OPERATOR_UNSPECIFIED":   0,
		"BINARY_OPERATOR_EQUAL":         1,
		"BINARY_OPERATOR_NOT_EQUAL":     2,
		"BINARY_OPERATOR_GREATER":       3,
		"BINARY_OPERATOR_GREATER_EQUAL": 4,
		"BINARY_OPERATOR_LESS":          5,
		"BINARY_OPERATOR_LESS_EQUAL":    6,
		"BINARY_OPERATOR_AND":           7,
		"BINARY_OPERATOR_OR":            8,
		"BINARY_OPERATOR_IN":            9,
		"BINARY_OPERATOR_CONTAINS":      10,
		"BINARY_OPERATOR_ADD":           11,
		"BINARY_OPERATOR_SUBTRACT":      12,
		"BINARY_OPERATOR_MULTIPLY":      13,
		"BINARY_OPERATOR_DIVIDE":        14,
		"BINARY_OPERATOR_MODULO":        15,
		"BINARY_OPERATOR_MATCHES":       16,
		"BINARY_OPERATOR_STARTS_WITH":   17,
		"BINARY_OPERATOR_ENDS_WITH":     18,
	}
)

Enum value maps for BinaryOperator.

View Source 
var (
	IdempotencyPolicy_name = map[int32]string{
		0: "IDEMPOTENCY_POLICY_UNSPECIFIED",
		1: "IDEMPOTENCY_POLICY_NONE",
		2: "IDEMPOTENCY_POLICY_KEY_REQUIRED",
		3: "IDEMPOTENCY_POLICY_SINK_GUARANTEED",
	}
	IdempotencyPolicy_value = map[string]int32{
		"IDEMPOTENCY_POLICY_UNSPECIFIED":     0,
		"IDEMPOTENCY_POLICY_NONE":            1,
		"IDEMPOTENCY_POLICY_KEY_REQUIRED":    2,
		"IDEMPOTENCY_POLICY_SINK_GUARANTEED": 3,
	}
)

Enum value maps for IdempotencyPolicy.

View Source 
var (
	FencingRequirement_name = map[int32]string{
		0: "FENCING_REQUIREMENT_UNSPECIFIED",
		1: "FENCING_REQUIREMENT_NONE",
		2: "FENCING_REQUIREMENT_REQUIRED",
	}
	FencingRequirement_value = map[string]int32{
		"FENCING_REQUIREMENT_UNSPECIFIED": 0,
		"FENCING_REQUIREMENT_NONE":        1,
		"FENCING_REQUIREMENT_REQUIRED":    2,
	}
)

Enum value maps for FencingRequirement.

View Source 
var (
	NullValue_name = map[int32]string{
		0: "NULL_VALUE_UNSPECIFIED",
		1: "NULL_VALUE_NULL",
	}
	NullValue_value = map[string]int32{
		"NULL_VALUE_UNSPECIFIED": 0,
		"NULL_VALUE_NULL":        1,
	}
)

Enum value maps for NullValue.

View Source 
var (
	DataSensitivityLevel_name = map[int32]string{
		0: "DATA_SENSITIVITY_LEVEL_UNSPECIFIED",
		1: "DATA_SENSITIVITY_LEVEL_PUBLIC",
		2: "DATA_SENSITIVITY_LEVEL_INTERNAL",
		3: "DATA_SENSITIVITY_LEVEL_CONFIDENTIAL",
		4: "DATA_SENSITIVITY_LEVEL_RESTRICTED",
	}
	DataSensitivityLevel_value = map[string]int32{
		"DATA_SENSITIVITY_LEVEL_UNSPECIFIED":  0,
		"DATA_SENSITIVITY_LEVEL_PUBLIC":       1,
		"DATA_SENSITIVITY_LEVEL_INTERNAL":     2,
		"DATA_SENSITIVITY_LEVEL_CONFIDENTIAL": 3,
		"DATA_SENSITIVITY_LEVEL_RESTRICTED":   4,
	}
)

Enum value maps for DataSensitivityLevel.

View Source 
var (
	VerbExecutionStatus_name = map[int32]string{
		0: "VERB_EXECUTION_STATUS_UNSPECIFIED",
		1: "VERB_EXECUTION_STATUS_SUCCESS",
		2: "VERB_EXECUTION_STATUS_ERROR",
		3: "VERB_EXECUTION_STATUS_TIMEOUT",
		4: "VERB_EXECUTION_STATUS_CANCELLED",
		5: "VERB_EXECUTION_STATUS_RATE_LIMITED",
		6: "VERB_EXECUTION_STATUS_CAPABILITY_DENIED",
	}
	VerbExecutionStatus_value = map[string]int32{
		"VERB_EXECUTION_STATUS_UNSPECIFIED":       0,
		"VERB_EXECUTION_STATUS_SUCCESS":           1,
		"VERB_EXECUTION_STATUS_ERROR":             2,
		"VERB_EXECUTION_STATUS_TIMEOUT":           3,
		"VERB_EXECUTION_STATUS_CANCELLED":         4,
		"VERB_EXECUTION_STATUS_RATE_LIMITED":      5,
		"VERB_EXECUTION_STATUS_CAPABILITY_DENIED": 6,
	}
)

Enum value maps for VerbExecutionStatus.

View Source 
var (
	CodeGenerationTarget_name = map[int32]string{
		0: "CODE_GENERATION_TARGET_UNSPECIFIED",
		1: "CODE_GENERATION_TARGET_GO",
		2: "CODE_GENERATION_TARGET_PYTHON",
		3: "CODE_GENERATION_TARGET_TYPESCRIPT",
		4: "CODE_GENERATION_TARGET_JAVA",
		5: "CODE_GENERATION_TARGET_RUST",
		6: "CODE_GENERATION_TARGET_CSHARP",
	}
	CodeGenerationTarget_value = map[string]int32{
		"CODE_GENERATION_TARGET_UNSPECIFIED": 0,
		"CODE_GENERATION_TARGET_GO":          1,
		"CODE_GENERATION_TARGET_PYTHON":      2,
		"CODE_GENERATION_TARGET_TYPESCRIPT":  3,
		"CODE_GENERATION_TARGET_JAVA":        4,
		"CODE_GENERATION_TARGET_RUST":        5,
		"CODE_GENERATION_TARGET_CSHARP":      6,
	}
)

Enum value maps for CodeGenerationTarget.

View Source 
var FactRegistryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "effectus.v1.FactRegistryService",
	HandlerType: (*FactRegistryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterFactSchema",
			Handler:    _FactRegistryService_RegisterFactSchema_Handler,
		},
		{
			MethodName: "GetFactSchema",
			Handler:    _FactRegistryService_GetFactSchema_Handler,
		},
		{
			MethodName: "ListFactSchemas",
			Handler:    _FactRegistryService_ListFactSchemas_Handler,
		},
		{
			MethodName: "ValidateFactData",
			Handler:    _FactRegistryService_ValidateFactData_Handler,
		},
		{
			MethodName: "CheckCompatibility",
			Handler:    _FactRegistryService_CheckCompatibility_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "effectus/v1/facts.proto",
}

FactRegistryService_ServiceDesc is the grpc.ServiceDesc for FactRegistryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_effectus_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_effectus_v1_execution_proto protoreflect.FileDescriptor
View Source 
var File_effectus_v1_facts_proto protoreflect.FileDescriptor
View Source 
var File_effectus_v1_ir_proto protoreflect.FileDescriptor
View Source 
var File_effectus_v1_verbs_proto protoreflect.FileDescriptor
View Source 
var RulesetExecutionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "effectus.v1.RulesetExecutionService",
	HandlerType: (*RulesetExecutionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecuteRuleset",
			Handler:    _RulesetExecutionService_ExecuteRuleset_Handler,
		},
		{
			MethodName: "GetRulesetInfo",
			Handler:    _RulesetExecutionService_GetRulesetInfo_Handler,
		},
		{
			MethodName: "ListRulesets",
			Handler:    _RulesetExecutionService_ListRulesets_Handler,
		},
		{
			MethodName: "RegisterRuleset",
			Handler:    _RulesetExecutionService_RegisterRuleset_Handler,
		},
		{
			MethodName: "UnregisterRuleset",
			Handler:    _RulesetExecutionService_UnregisterRuleset_Handler,
		},
		{
			MethodName: "ValidateSchema",
			Handler:    _RulesetExecutionService_ValidateSchema_Handler,
		},
		{
			MethodName: "GetSchemaVersion",
			Handler:    _RulesetExecutionService_GetSchemaVersion_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamExecution",
			Handler:       _RulesetExecutionService_StreamExecution_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "effectus/v1/execution.proto",
}

RulesetExecutionService_ServiceDesc is the grpc.ServiceDesc for RulesetExecutionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var VerbRegistryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "effectus.v1.VerbRegistryService",
	HandlerType: (*VerbRegistryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterVerbInterface",
			Handler:    _VerbRegistryService_RegisterVerbInterface_Handler,
		},
		{
			MethodName: "GetVerbInterface",
			Handler:    _VerbRegistryService_GetVerbInterface_Handler,
		},
		{
			MethodName: "ListVerbInterfaces",
			Handler:    _VerbRegistryService_ListVerbInterfaces_Handler,
		},
		{
			MethodName: "ValidateVerbCall",
			Handler:    _VerbRegistryService_ValidateVerbCall_Handler,
		},
		{
			MethodName: "CheckInterfaceCompatibility",
			Handler:    _VerbRegistryService_CheckInterfaceCompatibility_Handler,
		},
		{
			MethodName: "GenerateVerbCode",
			Handler:    _VerbRegistryService_GenerateVerbCode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "effectus/v1/verbs.proto",
}

VerbRegistryService_ServiceDesc is the grpc.ServiceDesc for VerbRegistryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFactRegistryServiceServer 

func RegisterFactRegistryServiceServer(s grpc.ServiceRegistrar, srv FactRegistryServiceServer)

func RegisterRulesetExecutionServiceServer 

func RegisterRulesetExecutionServiceServer(s grpc.ServiceRegistrar, srv RulesetExecutionServiceServer)

func RegisterVerbRegistryServiceServer 

func RegisterVerbRegistryServiceServer(s grpc.ServiceRegistrar, srv VerbRegistryServiceServer)

Types

type Argument 

type Argument struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Argument) Descriptor deprecated 

func (*Argument) Descriptor() ([]byte, []int)

Deprecated: Use Argument.ProtoReflect.Descriptor instead.

func (*Argument) GetName 

func (x *Argument) GetName() string

func (*Argument) GetValue 

func (x *Argument) GetValue() *Value

func (*Argument) ProtoMessage 

func (*Argument) ProtoMessage()

func (*Argument) ProtoReflect 

func (x *Argument) ProtoReflect() protoreflect.Message

func (*Argument) Reset 

func (x *Argument) Reset()

func (*Argument) String 

func (x *Argument) String() string

type BinaryExpression 

type BinaryExpression struct {
	Operator BinaryOperator `protobuf:"varint,1,opt,name=operator,proto3,enum=effectus.v1.BinaryOperator" json:"operator,omitempty"`
	Left     *Expression    `protobuf:"bytes,2,opt,name=left,proto3" json:"left,omitempty"`
	Right    *Expression    `protobuf:"bytes,3,opt,name=right,proto3" json:"right,omitempty"`
	// contains filtered or unexported fields
}

func (*BinaryExpression) Descriptor deprecated 

func (*BinaryExpression) Descriptor() ([]byte, []int)

Deprecated: Use BinaryExpression.ProtoReflect.Descriptor instead.

func (*BinaryExpression) GetLeft 

func (x *BinaryExpression) GetLeft() *Expression

func (*BinaryExpression) GetOperator 

func (x *BinaryExpression) GetOperator() BinaryOperator

func (*BinaryExpression) GetRight 

func (x *BinaryExpression) GetRight() *Expression

func (*BinaryExpression) ProtoMessage 

func (*BinaryExpression) ProtoMessage()

func (*BinaryExpression) ProtoReflect 

func (x *BinaryExpression) ProtoReflect() protoreflect.Message

func (*BinaryExpression) Reset 

func (x *BinaryExpression) Reset()

func (*BinaryExpression) String 

func (x *BinaryExpression) String() string

type BinaryOperator 

type BinaryOperator int32
const (
	BinaryOperator_BINARY_OPERATOR_UNSPECIFIED   BinaryOperator = 0
	BinaryOperator_BINARY_OPERATOR_EQUAL         BinaryOperator = 1
	BinaryOperator_BINARY_OPERATOR_NOT_EQUAL     BinaryOperator = 2
	BinaryOperator_BINARY_OPERATOR_GREATER       BinaryOperator = 3
	BinaryOperator_BINARY_OPERATOR_GREATER_EQUAL BinaryOperator = 4
	BinaryOperator_BINARY_OPERATOR_LESS          BinaryOperator = 5
	BinaryOperator_BINARY_OPERATOR_LESS_EQUAL    BinaryOperator = 6
	BinaryOperator_BINARY_OPERATOR_AND           BinaryOperator = 7
	BinaryOperator_BINARY_OPERATOR_OR            BinaryOperator = 8
	BinaryOperator_BINARY_OPERATOR_IN            BinaryOperator = 9
	BinaryOperator_BINARY_OPERATOR_CONTAINS      BinaryOperator = 10
	BinaryOperator_BINARY_OPERATOR_ADD           BinaryOperator = 11
	BinaryOperator_BINARY_OPERATOR_SUBTRACT      BinaryOperator = 12
	BinaryOperator_BINARY_OPERATOR_MULTIPLY      BinaryOperator = 13
	BinaryOperator_BINARY_OPERATOR_DIVIDE        BinaryOperator = 14
	BinaryOperator_BINARY_OPERATOR_MODULO        BinaryOperator = 15
	BinaryOperator_BINARY_OPERATOR_MATCHES       BinaryOperator = 16
	BinaryOperator_BINARY_OPERATOR_STARTS_WITH   BinaryOperator = 17
	BinaryOperator_BINARY_OPERATOR_ENDS_WITH     BinaryOperator = 18
)

func (BinaryOperator) Descriptor 

func (BinaryOperator) Descriptor() protoreflect.EnumDescriptor

func (BinaryOperator) Enum 

func (x BinaryOperator) Enum() *BinaryOperator

func (BinaryOperator) EnumDescriptor deprecated 

func (BinaryOperator) EnumDescriptor() ([]byte, []int)

Deprecated: Use BinaryOperator.Descriptor instead.

func (BinaryOperator) Number 

func (x BinaryOperator) Number() protoreflect.EnumNumber

func (BinaryOperator) String 

func (x BinaryOperator) String() string

func (BinaryOperator) Type 

func (BinaryOperator) Type() protoreflect.EnumType

type CheckCompatibilityRequest 

type CheckCompatibilityRequest struct {
	SchemaName string `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	OldVersion string `protobuf:"bytes,2,opt,name=old_version,json=oldVersion,proto3" json:"old_version,omitempty"`
	NewVersion string `protobuf:"bytes,3,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckCompatibilityRequest) Descriptor deprecated 

func (*CheckCompatibilityRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckCompatibilityRequest.ProtoReflect.Descriptor instead.

func (*CheckCompatibilityRequest) GetNewVersion 

func (x *CheckCompatibilityRequest) GetNewVersion() string

func (*CheckCompatibilityRequest) GetOldVersion 

func (x *CheckCompatibilityRequest) GetOldVersion() string

func (*CheckCompatibilityRequest) GetSchemaName 

func (x *CheckCompatibilityRequest) GetSchemaName() string

func (*CheckCompatibilityRequest) ProtoMessage 

func (*CheckCompatibilityRequest) ProtoMessage()

func (*CheckCompatibilityRequest) ProtoReflect 

func (x *CheckCompatibilityRequest) ProtoReflect() protoreflect.Message

func (*CheckCompatibilityRequest) Reset 

func (x *CheckCompatibilityRequest) Reset()

func (*CheckCompatibilityRequest) String 

func (x *CheckCompatibilityRequest) String() string

type CheckCompatibilityResponse 

type CheckCompatibilityResponse struct {
	Compatible      bool     `protobuf:"varint,1,opt,name=compatible,proto3" json:"compatible,omitempty"`
	BreakingChanges []string `protobuf:"bytes,2,rep,name=breaking_changes,json=breakingChanges,proto3" json:"breaking_changes,omitempty"`
	Warnings        []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckCompatibilityResponse) Descriptor deprecated 

func (*CheckCompatibilityResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckCompatibilityResponse.ProtoReflect.Descriptor instead.

func (*CheckCompatibilityResponse) GetBreakingChanges 

func (x *CheckCompatibilityResponse) GetBreakingChanges() []string

func (*CheckCompatibilityResponse) GetCompatible 

func (x *CheckCompatibilityResponse) GetCompatible() bool

func (*CheckCompatibilityResponse) GetWarnings 

func (x *CheckCompatibilityResponse) GetWarnings() []string

func (*CheckCompatibilityResponse) ProtoMessage 

func (*CheckCompatibilityResponse) ProtoMessage()

func (*CheckCompatibilityResponse) ProtoReflect 

func (x *CheckCompatibilityResponse) ProtoReflect() protoreflect.Message

func (*CheckCompatibilityResponse) Reset 

func (x *CheckCompatibilityResponse) Reset()

func (*CheckCompatibilityResponse) String 

func (x *CheckCompatibilityResponse) String() string

type CheckInterfaceCompatibilityRequest 

type CheckInterfaceCompatibilityRequest struct {
	VerbName       string `protobuf:"bytes,1,opt,name=verb_name,json=verbName,proto3" json:"verb_name,omitempty"`
	CurrentVersion string `protobuf:"bytes,2,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"`
	TargetVersion  string `protobuf:"bytes,3,opt,name=target_version,json=targetVersion,proto3" json:"target_version,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckInterfaceCompatibilityRequest) Descriptor deprecated 

func (*CheckInterfaceCompatibilityRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckInterfaceCompatibilityRequest.ProtoReflect.Descriptor instead.

func (*CheckInterfaceCompatibilityRequest) GetCurrentVersion 

func (x *CheckInterfaceCompatibilityRequest) GetCurrentVersion() string

func (*CheckInterfaceCompatibilityRequest) GetTargetVersion 

func (x *CheckInterfaceCompatibilityRequest) GetTargetVersion() string

func (*CheckInterfaceCompatibilityRequest) GetVerbName 

func (x *CheckInterfaceCompatibilityRequest) GetVerbName() string

func (*CheckInterfaceCompatibilityRequest) ProtoMessage 

func (*CheckInterfaceCompatibilityRequest) ProtoMessage()

func (*CheckInterfaceCompatibilityRequest) ProtoReflect 

func (x *CheckInterfaceCompatibilityRequest) ProtoReflect() protoreflect.Message

func (*CheckInterfaceCompatibilityRequest) Reset 

func (x *CheckInterfaceCompatibilityRequest) Reset()

func (*CheckInterfaceCompatibilityRequest) String 

func (x *CheckInterfaceCompatibilityRequest) String() string

type CheckInterfaceCompatibilityResponse 

type CheckInterfaceCompatibilityResponse struct {
	Compatible         bool     `protobuf:"varint,1,opt,name=compatible,proto3" json:"compatible,omitempty"`
	BreakingChanges    []string `protobuf:"bytes,2,rep,name=breaking_changes,json=breakingChanges,proto3" json:"breaking_changes,omitempty"`
	Warnings           []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	CompatibilityLevel string   `protobuf:"bytes,4,opt,name=compatibility_level,json=compatibilityLevel,proto3" json:"compatibility_level,omitempty"` // "full", "backward", "forward", "none"
	// contains filtered or unexported fields
}

func (*CheckInterfaceCompatibilityResponse) Descriptor deprecated 

func (*CheckInterfaceCompatibilityResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckInterfaceCompatibilityResponse.ProtoReflect.Descriptor instead.

func (*CheckInterfaceCompatibilityResponse) GetBreakingChanges 

func (x *CheckInterfaceCompatibilityResponse) GetBreakingChanges() []string

func (*CheckInterfaceCompatibilityResponse) GetCompatibilityLevel 

func (x *CheckInterfaceCompatibilityResponse) GetCompatibilityLevel() string

func (*CheckInterfaceCompatibilityResponse) GetCompatible 

func (x *CheckInterfaceCompatibilityResponse) GetCompatible() bool

func (*CheckInterfaceCompatibilityResponse) GetWarnings 

func (x *CheckInterfaceCompatibilityResponse) GetWarnings() []string

func (*CheckInterfaceCompatibilityResponse) ProtoMessage 

func (*CheckInterfaceCompatibilityResponse) ProtoMessage()

func (*CheckInterfaceCompatibilityResponse) ProtoReflect 

func (x *CheckInterfaceCompatibilityResponse) ProtoReflect() protoreflect.Message

func (*CheckInterfaceCompatibilityResponse) Reset 

func (x *CheckInterfaceCompatibilityResponse) Reset()

func (*CheckInterfaceCompatibilityResponse) String 

func (x *CheckInterfaceCompatibilityResponse) String() string

type CheckedRetryPolicy 

type CheckedRetryPolicy struct {
	MaxAttempts          uint32 `protobuf:"varint,1,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	InitialBackoffMillis uint64 `protobuf:"varint,2,opt,name=initial_backoff_millis,json=initialBackoffMillis,proto3" json:"initial_backoff_millis,omitempty"`
	MaxBackoffMillis     uint64 `protobuf:"varint,3,opt,name=max_backoff_millis,json=maxBackoffMillis,proto3" json:"max_backoff_millis,omitempty"`
	// contains filtered or unexported fields
}

RetryPolicy is part of a checked verb contract, not mutable adapter state.

func (*CheckedRetryPolicy) Descriptor deprecated 

func (*CheckedRetryPolicy) Descriptor() ([]byte, []int)

Deprecated: Use CheckedRetryPolicy.ProtoReflect.Descriptor instead.

func (*CheckedRetryPolicy) GetInitialBackoffMillis 

func (x *CheckedRetryPolicy) GetInitialBackoffMillis() uint64

func (*CheckedRetryPolicy) GetMaxAttempts 

func (x *CheckedRetryPolicy) GetMaxAttempts() uint32

func (*CheckedRetryPolicy) GetMaxBackoffMillis 

func (x *CheckedRetryPolicy) GetMaxBackoffMillis() uint64

func (*CheckedRetryPolicy) ProtoMessage 

func (*CheckedRetryPolicy) ProtoMessage()

func (*CheckedRetryPolicy) ProtoReflect 

func (x *CheckedRetryPolicy) ProtoReflect() protoreflect.Message

func (*CheckedRetryPolicy) Reset 

func (x *CheckedRetryPolicy) Reset()

func (*CheckedRetryPolicy) String 

func (x *CheckedRetryPolicy) String() string

type CodeGenerationTarget 

type CodeGenerationTarget int32

CodeGenerationTarget defines the target language/framework for code generation 

const (
	CodeGenerationTarget_CODE_GENERATION_TARGET_UNSPECIFIED CodeGenerationTarget = 0
	CodeGenerationTarget_CODE_GENERATION_TARGET_GO          CodeGenerationTarget = 1
	CodeGenerationTarget_CODE_GENERATION_TARGET_PYTHON      CodeGenerationTarget = 2
	CodeGenerationTarget_CODE_GENERATION_TARGET_TYPESCRIPT  CodeGenerationTarget = 3
	CodeGenerationTarget_CODE_GENERATION_TARGET_JAVA        CodeGenerationTarget = 4
	CodeGenerationTarget_CODE_GENERATION_TARGET_RUST        CodeGenerationTarget = 5
	CodeGenerationTarget_CODE_GENERATION_TARGET_CSHARP      CodeGenerationTarget = 6
)

func (CodeGenerationTarget) Descriptor 

func (CodeGenerationTarget) Descriptor() protoreflect.EnumDescriptor

func (CodeGenerationTarget) Enum 

func (x CodeGenerationTarget) Enum() *CodeGenerationTarget

func (CodeGenerationTarget) EnumDescriptor deprecated 

func (CodeGenerationTarget) EnumDescriptor() ([]byte, []int)

Deprecated: Use CodeGenerationTarget.Descriptor instead.

func (CodeGenerationTarget) Number 

func (x CodeGenerationTarget) Number() protoreflect.EnumNumber

func (CodeGenerationTarget) String 

func (x CodeGenerationTarget) String() string

func (CodeGenerationTarget) Type 

func (CodeGenerationTarget) Type() protoreflect.EnumType

type CompatibilityInfo 

type CompatibilityInfo struct {
	CompatibleVersions   []string               `protobuf:"bytes,1,rep,name=compatible_versions,json=compatibleVersions,proto3" json:"compatible_versions,omitempty"`
	BreakingChangesSince []string               `protobuf:"bytes,2,rep,name=breaking_changes_since,json=breakingChangesSince,proto3" json:"breaking_changes_since,omitempty"`
	MigrationGuide       string                 `protobuf:"bytes,3,opt,name=migration_guide,json=migrationGuide,proto3" json:"migration_guide,omitempty"`
	DeprecationNotice    string                 `protobuf:"bytes,4,opt,name=deprecation_notice,json=deprecationNotice,proto3" json:"deprecation_notice,omitempty"`
	DeprecationDate      *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=deprecation_date,json=deprecationDate,proto3" json:"deprecation_date,omitempty"`
	// contains filtered or unexported fields
}

CompatibilityInfo tracks compatibility between versions

func (*CompatibilityInfo) Descriptor deprecated 

func (*CompatibilityInfo) Descriptor() ([]byte, []int)

Deprecated: Use CompatibilityInfo.ProtoReflect.Descriptor instead.

func (*CompatibilityInfo) GetBreakingChangesSince 

func (x *CompatibilityInfo) GetBreakingChangesSince() []string

func (*CompatibilityInfo) GetCompatibleVersions 

func (x *CompatibilityInfo) GetCompatibleVersions() []string

func (*CompatibilityInfo) GetDeprecationDate 

func (x *CompatibilityInfo) GetDeprecationDate() *timestamppb.Timestamp

func (*CompatibilityInfo) GetDeprecationNotice 

func (x *CompatibilityInfo) GetDeprecationNotice() string

func (*CompatibilityInfo) GetMigrationGuide 

func (x *CompatibilityInfo) GetMigrationGuide() string

func (*CompatibilityInfo) ProtoMessage 

func (*CompatibilityInfo) ProtoMessage()

func (*CompatibilityInfo) ProtoReflect 

func (x *CompatibilityInfo) ProtoReflect() protoreflect.Message

func (*CompatibilityInfo) Reset 

func (x *CompatibilityInfo) Reset()

func (*CompatibilityInfo) String 

func (x *CompatibilityInfo) String() string

type CompensationContract 

type CompensationContract struct {
	InverseVerb         string `protobuf:"bytes,1,opt,name=inverse_verb,json=inverseVerb,proto3" json:"inverse_verb,omitempty"`
	InverseContractHash string `protobuf:"bytes,2,opt,name=inverse_contract_hash,json=inverseContractHash,proto3" json:"inverse_contract_hash,omitempty"`
	// contains filtered or unexported fields
}

CompensationContract freezes the inverse selected during compilation.

func (*CompensationContract) Descriptor deprecated 

func (*CompensationContract) Descriptor() ([]byte, []int)

Deprecated: Use CompensationContract.ProtoReflect.Descriptor instead.

func (*CompensationContract) GetInverseContractHash 

func (x *CompensationContract) GetInverseContractHash() string

func (*CompensationContract) GetInverseVerb 

func (x *CompensationContract) GetInverseVerb() string

func (*CompensationContract) ProtoMessage 

func (*CompensationContract) ProtoMessage()

func (*CompensationContract) ProtoReflect 

func (x *CompensationContract) ProtoReflect() protoreflect.Message

func (*CompensationContract) Reset 

func (x *CompensationContract) Reset()

func (*CompensationContract) String 

func (x *CompensationContract) String() string

type CompiledEffect 

type CompiledEffect struct {
	VerbName string                `protobuf:"bytes,1,opt,name=verb_name,json=verbName,proto3" json:"verb_name,omitempty"`
	Args     map[string]*anypb.Any `` /* 135-byte string literal not displayed */
	// Schema information
	EffectSchemaVersion  string `protobuf:"bytes,3,opt,name=effect_schema_version,json=effectSchemaVersion,proto3" json:"effect_schema_version,omitempty"`
	VerbInterfaceVersion string `protobuf:"bytes,4,opt,name=verb_interface_version,json=verbInterfaceVersion,proto3" json:"verb_interface_version,omitempty"`
	// contains filtered or unexported fields
}

CompiledEffect represents a compiled effect

func (*CompiledEffect) Descriptor deprecated 

func (*CompiledEffect) Descriptor() ([]byte, []int)

Deprecated: Use CompiledEffect.ProtoReflect.Descriptor instead.

func (*CompiledEffect) GetArgs 

func (x *CompiledEffect) GetArgs() map[string]*anypb.Any

func (*CompiledEffect) GetEffectSchemaVersion 

func (x *CompiledEffect) GetEffectSchemaVersion() string

func (*CompiledEffect) GetVerbInterfaceVersion 

func (x *CompiledEffect) GetVerbInterfaceVersion() string

func (*CompiledEffect) GetVerbName 

func (x *CompiledEffect) GetVerbName() string

func (*CompiledEffect) ProtoMessage 

func (*CompiledEffect) ProtoMessage()

func (*CompiledEffect) ProtoReflect 

func (x *CompiledEffect) ProtoReflect() protoreflect.Message

func (*CompiledEffect) Reset 

func (x *CompiledEffect) Reset()

func (*CompiledEffect) String 

func (x *CompiledEffect) String() string

type CompiledPredicate 

type CompiledPredicate struct {
	Path     string     `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Operator string     `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	Value    *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// Schema validation for the predicate
	FieldSchemaVersion string `protobuf:"bytes,4,opt,name=field_schema_version,json=fieldSchemaVersion,proto3" json:"field_schema_version,omitempty"`
	// contains filtered or unexported fields
}

CompiledPredicate represents a compiled predicate

func (*CompiledPredicate) Descriptor deprecated 

func (*CompiledPredicate) Descriptor() ([]byte, []int)

Deprecated: Use CompiledPredicate.ProtoReflect.Descriptor instead.

func (*CompiledPredicate) GetFieldSchemaVersion 

func (x *CompiledPredicate) GetFieldSchemaVersion() string

func (*CompiledPredicate) GetOperator 

func (x *CompiledPredicate) GetOperator() string

func (*CompiledPredicate) GetPath 

func (x *CompiledPredicate) GetPath() string

func (*CompiledPredicate) GetValue 

func (x *CompiledPredicate) GetValue() *anypb.Any

func (*CompiledPredicate) ProtoMessage 

func (*CompiledPredicate) ProtoMessage()

func (*CompiledPredicate) ProtoReflect 

func (x *CompiledPredicate) ProtoReflect() protoreflect.Message

func (*CompiledPredicate) Reset 

func (x *CompiledPredicate) Reset()

func (*CompiledPredicate) String 

func (x *CompiledPredicate) String() string

type CompiledRule 

type CompiledRule struct {
	Name        string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type        RuleType             `protobuf:"varint,2,opt,name=type,proto3,enum=effectus.v1.RuleType" json:"type,omitempty"`
	Predicates  []*CompiledPredicate `protobuf:"bytes,3,rep,name=predicates,proto3" json:"predicates,omitempty"`
	Effects     []*CompiledEffect    `protobuf:"bytes,4,rep,name=effects,proto3" json:"effects,omitempty"`
	Priority    int32                `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	Description string               `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Schema compatibility requirements
	MinSchemaVersion string `protobuf:"bytes,7,opt,name=min_schema_version,json=minSchemaVersion,proto3" json:"min_schema_version,omitempty"`
	// contains filtered or unexported fields
}

CompiledRule represents a compiled rule within a ruleset

func (*CompiledRule) Descriptor deprecated 

func (*CompiledRule) Descriptor() ([]byte, []int)

Deprecated: Use CompiledRule.ProtoReflect.Descriptor instead.

func (*CompiledRule) GetDescription 

func (x *CompiledRule) GetDescription() string

func (*CompiledRule) GetEffects 

func (x *CompiledRule) GetEffects() []*CompiledEffect

func (*CompiledRule) GetMinSchemaVersion 

func (x *CompiledRule) GetMinSchemaVersion() string

func (*CompiledRule) GetName 

func (x *CompiledRule) GetName() string

func (*CompiledRule) GetPredicates 

func (x *CompiledRule) GetPredicates() []*CompiledPredicate

func (*CompiledRule) GetPriority 

func (x *CompiledRule) GetPriority() int32

func (*CompiledRule) GetType 

func (x *CompiledRule) GetType() RuleType

func (*CompiledRule) ProtoMessage 

func (*CompiledRule) ProtoMessage()

func (*CompiledRule) ProtoReflect 

func (x *CompiledRule) ProtoReflect() protoreflect.Message

func (*CompiledRule) Reset 

func (x *CompiledRule) Reset()

func (*CompiledRule) String 

func (x *CompiledRule) String() string

type CompiledRuleset 

type CompiledRuleset struct {
	Name          string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version       string             `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Description   string             `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	FactSchema    *Schema            `protobuf:"bytes,4,opt,name=fact_schema,json=factSchema,proto3" json:"fact_schema,omitempty"`
	EffectSchemas map[string]*Schema `` /* 174-byte string literal not displayed */
	Rules         []*CompiledRule    `protobuf:"bytes,6,rep,name=rules,proto3" json:"rules,omitempty"`
	Dependencies  []string           `protobuf:"bytes,7,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	Capabilities  []string           `protobuf:"bytes,8,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	Metadata      map[string]string  `` /* 143-byte string literal not displayed */
	// Schema versioning information
	SchemaVersions *SchemaVersionInfo `protobuf:"bytes,10,opt,name=schema_versions,json=schemaVersions,proto3" json:"schema_versions,omitempty"`
	// contains filtered or unexported fields
}

CompiledRuleset represents a compiled and validated ruleset

func (*CompiledRuleset) Descriptor deprecated 

func (*CompiledRuleset) Descriptor() ([]byte, []int)

Deprecated: Use CompiledRuleset.ProtoReflect.Descriptor instead.

func (*CompiledRuleset) GetCapabilities 

func (x *CompiledRuleset) GetCapabilities() []string

func (*CompiledRuleset) GetDependencies 

func (x *CompiledRuleset) GetDependencies() []string

func (*CompiledRuleset) GetDescription 

func (x *CompiledRuleset) GetDescription() string

func (*CompiledRuleset) GetEffectSchemas 

func (x *CompiledRuleset) GetEffectSchemas() map[string]*Schema

func (*CompiledRuleset) GetFactSchema 

func (x *CompiledRuleset) GetFactSchema() *Schema

func (*CompiledRuleset) GetMetadata 

func (x *CompiledRuleset) GetMetadata() map[string]string

func (*CompiledRuleset) GetName 

func (x *CompiledRuleset) GetName() string

func (*CompiledRuleset) GetRules 

func (x *CompiledRuleset) GetRules() []*CompiledRule

func (*CompiledRuleset) GetSchemaVersions 

func (x *CompiledRuleset) GetSchemaVersions() *SchemaVersionInfo

func (*CompiledRuleset) GetVersion 

func (x *CompiledRuleset) GetVersion() string

func (*CompiledRuleset) ProtoMessage 

func (*CompiledRuleset) ProtoMessage()

func (*CompiledRuleset) ProtoReflect 

func (x *CompiledRuleset) ProtoReflect() protoreflect.Message

func (*CompiledRuleset) Reset 

func (x *CompiledRuleset) Reset()

func (*CompiledRuleset) String 

func (x *CompiledRuleset) String() string

type CompilerMetadata 

type CompilerMetadata struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version     string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	BuildDigest string `protobuf:"bytes,3,opt,name=build_digest,json=buildDigest,proto3" json:"build_digest,omitempty"`
	// contains filtered or unexported fields
}

func (*CompilerMetadata) Descriptor deprecated 

func (*CompilerMetadata) Descriptor() ([]byte, []int)

Deprecated: Use CompilerMetadata.ProtoReflect.Descriptor instead.

func (*CompilerMetadata) GetBuildDigest 

func (x *CompilerMetadata) GetBuildDigest() string

func (*CompilerMetadata) GetName 

func (x *CompilerMetadata) GetName() string

func (*CompilerMetadata) GetVersion 

func (x *CompilerMetadata) GetVersion() string

func (*CompilerMetadata) ProtoMessage 

func (*CompilerMetadata) ProtoMessage()

func (*CompilerMetadata) ProtoReflect 

func (x *CompilerMetadata) ProtoReflect() protoreflect.Message

func (*CompilerMetadata) Reset 

func (x *CompilerMetadata) Reset()

func (*CompilerMetadata) String 

func (x *CompilerMetadata) String() string

type DataSensitivityLevel 

type DataSensitivityLevel int32

DataSensitivityLevel defines data sensitivity levels 

const (
	DataSensitivityLevel_DATA_SENSITIVITY_LEVEL_UNSPECIFIED  DataSensitivityLevel = 0
	DataSensitivityLevel_DATA_SENSITIVITY_LEVEL_PUBLIC       DataSensitivityLevel = 1
	DataSensitivityLevel_DATA_SENSITIVITY_LEVEL_INTERNAL     DataSensitivityLevel = 2
	DataSensitivityLevel_DATA_SENSITIVITY_LEVEL_CONFIDENTIAL DataSensitivityLevel = 3
	DataSensitivityLevel_DATA_SENSITIVITY_LEVEL_RESTRICTED   DataSensitivityLevel = 4
)

func (DataSensitivityLevel) Descriptor 

func (DataSensitivityLevel) Descriptor() protoreflect.EnumDescriptor

func (DataSensitivityLevel) Enum 

func (x DataSensitivityLevel) Enum() *DataSensitivityLevel

func (DataSensitivityLevel) EnumDescriptor deprecated 

func (DataSensitivityLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use DataSensitivityLevel.Descriptor instead.

func (DataSensitivityLevel) Number 

func (x DataSensitivityLevel) Number() protoreflect.EnumNumber

func (DataSensitivityLevel) String 

func (x DataSensitivityLevel) String() string

func (DataSensitivityLevel) Type 

func (DataSensitivityLevel) Type() protoreflect.EnumType

type EffectStatus 

type EffectStatus int32

EffectStatus represents the execution status of an effect 

const (
	EffectStatus_EFFECT_STATUS_UNSPECIFIED  EffectStatus = 0
	EffectStatus_EFFECT_STATUS_PENDING      EffectStatus = 1
	EffectStatus_EFFECT_STATUS_EXECUTED     EffectStatus = 2
	EffectStatus_EFFECT_STATUS_FAILED       EffectStatus = 3
	EffectStatus_EFFECT_STATUS_SKIPPED      EffectStatus = 4
	EffectStatus_EFFECT_STATUS_RETRYING     EffectStatus = 5
	EffectStatus_EFFECT_STATUS_COMPENSATING EffectStatus = 6
)

func (EffectStatus) Descriptor 

func (EffectStatus) Descriptor() protoreflect.EnumDescriptor

func (EffectStatus) Enum 

func (x EffectStatus) Enum() *EffectStatus

func (EffectStatus) EnumDescriptor deprecated 

func (EffectStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use EffectStatus.Descriptor instead.

func (EffectStatus) Number 

func (x EffectStatus) Number() protoreflect.EnumNumber

func (EffectStatus) String 

func (x EffectStatus) String() string

func (EffectStatus) Type 

func (EffectStatus) Type() protoreflect.EnumType

type ErrorDefinition 

type ErrorDefinition struct {
	ErrorCode          int32   `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	ErrorName          string  `protobuf:"bytes,2,opt,name=error_name,json=errorName,proto3" json:"error_name,omitempty"`
	Description        string  `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	ErrorSchema        *Schema `protobuf:"bytes,4,opt,name=error_schema,json=errorSchema,proto3" json:"error_schema,omitempty"` // Schema for error details
	Retryable          bool    `protobuf:"varint,5,opt,name=retryable,proto3" json:"retryable,omitempty"`
	MitigationGuidance string  `protobuf:"bytes,6,opt,name=mitigation_guidance,json=mitigationGuidance,proto3" json:"mitigation_guidance,omitempty"`
	// contains filtered or unexported fields
}

ErrorDefinition defines possible errors a verb can return

func (*ErrorDefinition) Descriptor deprecated 

func (*ErrorDefinition) Descriptor() ([]byte, []int)

Deprecated: Use ErrorDefinition.ProtoReflect.Descriptor instead.

func (*ErrorDefinition) GetDescription 

func (x *ErrorDefinition) GetDescription() string

func (*ErrorDefinition) GetErrorCode 

func (x *ErrorDefinition) GetErrorCode() int32

func (*ErrorDefinition) GetErrorName 

func (x *ErrorDefinition) GetErrorName() string

func (*ErrorDefinition) GetErrorSchema 

func (x *ErrorDefinition) GetErrorSchema() *Schema

func (*ErrorDefinition) GetMitigationGuidance 

func (x *ErrorDefinition) GetMitigationGuidance() string

func (*ErrorDefinition) GetRetryable 

func (x *ErrorDefinition) GetRetryable() bool

func (*ErrorDefinition) ProtoMessage 

func (*ErrorDefinition) ProtoMessage()

func (*ErrorDefinition) ProtoReflect 

func (x *ErrorDefinition) ProtoReflect() protoreflect.Message

func (*ErrorDefinition) Reset 

func (x *ErrorDefinition) Reset()

func (*ErrorDefinition) String 

func (x *ErrorDefinition) String() string

type ExecutionContext 

type ExecutionContext struct {
	CallerId     string            `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	SessionId    string            `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	RequestId    string            `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Headers      map[string]string `` /* 141-byte string literal not displayed */
	Capabilities []string          `protobuf:"bytes,5,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// Security context
	Security *SecurityContext `protobuf:"bytes,6,opt,name=security,proto3" json:"security,omitempty"`
	// contains filtered or unexported fields
}

ExecutionContext provides context for verb execution

func (*ExecutionContext) Descriptor deprecated 

func (*ExecutionContext) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionContext.ProtoReflect.Descriptor instead.

func (*ExecutionContext) GetCallerId 

func (x *ExecutionContext) GetCallerId() string

func (*ExecutionContext) GetCapabilities 

func (x *ExecutionContext) GetCapabilities() []string

func (*ExecutionContext) GetHeaders 

func (x *ExecutionContext) GetHeaders() map[string]string

func (*ExecutionContext) GetRequestId 

func (x *ExecutionContext) GetRequestId() string

func (*ExecutionContext) GetSecurity 

func (x *ExecutionContext) GetSecurity() *SecurityContext

func (*ExecutionContext) GetSessionId 

func (x *ExecutionContext) GetSessionId() string

func (*ExecutionContext) ProtoMessage 

func (*ExecutionContext) ProtoMessage()

func (*ExecutionContext) ProtoReflect 

func (x *ExecutionContext) ProtoReflect() protoreflect.Message

func (*ExecutionContext) Reset 

func (x *ExecutionContext) Reset()

func (*ExecutionContext) String 

func (x *ExecutionContext) String() string

type ExecutionOptions 

type ExecutionOptions struct {

	// Deprecated: Marked as deprecated in effectus/v1/execution.proto.
	DryRun bool `protobuf:"varint,1,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// Deprecated: Marked as deprecated in effectus/v1/execution.proto.
	MaxEffects     int32 `protobuf:"varint,2,opt,name=max_effects,json=maxEffects,proto3" json:"max_effects,omitempty"`
	TimeoutSeconds int32 `protobuf:"varint,3,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	// Deprecated: Marked as deprecated in effectus/v1/execution.proto.
	EnableTracing bool `protobuf:"varint,4,opt,name=enable_tracing,json=enableTracing,proto3" json:"enable_tracing,omitempty"`
	// Deprecated: Marked as deprecated in effectus/v1/execution.proto.
	CapabilityFilter []string `protobuf:"bytes,5,rep,name=capability_filter,json=capabilityFilter,proto3" json:"capability_filter,omitempty"`
	// Unsupported Buf-managed schema version constraints.
	//
	// Deprecated: Marked as deprecated in effectus/v1/execution.proto.
	MinSchemaVersion string `protobuf:"bytes,6,opt,name=min_schema_version,json=minSchemaVersion,proto3" json:"min_schema_version,omitempty"`
	// Deprecated: Marked as deprecated in effectus/v1/execution.proto.
	MaxSchemaVersion string `protobuf:"bytes,7,opt,name=max_schema_version,json=maxSchemaVersion,proto3" json:"max_schema_version,omitempty"`
	// contains filtered or unexported fields
}

ExecutionOptions provides options for rule execution. effectusd supports only timeout_seconds. Other fields are preserved for wire compatibility.

func (*ExecutionOptions) Descriptor deprecated 

func (*ExecutionOptions) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionOptions.ProtoReflect.Descriptor instead.

func (*ExecutionOptions) GetCapabilityFilter deprecated 

func (x *ExecutionOptions) GetCapabilityFilter() []string

Deprecated: Marked as deprecated in effectus/v1/execution.proto.

func (*ExecutionOptions) GetDryRun deprecated 

func (x *ExecutionOptions) GetDryRun() bool

Deprecated: Marked as deprecated in effectus/v1/execution.proto.

func (*ExecutionOptions) GetEnableTracing deprecated 

func (x *ExecutionOptions) GetEnableTracing() bool

Deprecated: Marked as deprecated in effectus/v1/execution.proto.

func (*ExecutionOptions) GetMaxEffects deprecated 

func (x *ExecutionOptions) GetMaxEffects() int32

Deprecated: Marked as deprecated in effectus/v1/execution.proto.

func (*ExecutionOptions) GetMaxSchemaVersion deprecated 

func (x *ExecutionOptions) GetMaxSchemaVersion() string

Deprecated: Marked as deprecated in effectus/v1/execution.proto.

func (*ExecutionOptions) GetMinSchemaVersion deprecated 

func (x *ExecutionOptions) GetMinSchemaVersion() string

Deprecated: Marked as deprecated in effectus/v1/execution.proto.

func (*ExecutionOptions) GetTimeoutSeconds 

func (x *ExecutionOptions) GetTimeoutSeconds() int32

func (*ExecutionOptions) ProtoMessage 

func (*ExecutionOptions) ProtoMessage()

func (*ExecutionOptions) ProtoReflect 

func (x *ExecutionOptions) ProtoReflect() protoreflect.Message

func (*ExecutionOptions) Reset 

func (x *ExecutionOptions) Reset()

func (*ExecutionOptions) String 

func (x *ExecutionOptions) String() string

type ExecutionPhase 

type ExecutionPhase int32

ExecutionPhase represents the current phase of execution 

const (
	ExecutionPhase_EXECUTION_PHASE_UNSPECIFIED  ExecutionPhase = 0
	ExecutionPhase_EXECUTION_PHASE_VALIDATION   ExecutionPhase = 1
	ExecutionPhase_EXECUTION_PHASE_SCHEMA_CHECK ExecutionPhase = 2
	ExecutionPhase_EXECUTION_PHASE_COMPILATION  ExecutionPhase = 3
	ExecutionPhase_EXECUTION_PHASE_EXECUTION    ExecutionPhase = 4
	ExecutionPhase_EXECUTION_PHASE_COMPLETION   ExecutionPhase = 5
	ExecutionPhase_EXECUTION_PHASE_ERROR        ExecutionPhase = 6
)

func (ExecutionPhase) Descriptor 

func (ExecutionPhase) Descriptor() protoreflect.EnumDescriptor

func (ExecutionPhase) Enum 

func (x ExecutionPhase) Enum() *ExecutionPhase

func (ExecutionPhase) EnumDescriptor deprecated 

func (ExecutionPhase) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecutionPhase.Descriptor instead.

func (ExecutionPhase) Number 

func (x ExecutionPhase) Number() protoreflect.EnumNumber

func (ExecutionPhase) String 

func (x ExecutionPhase) String() string

func (ExecutionPhase) Type 

func (ExecutionPhase) Type() protoreflect.EnumType

type ExecutionPolicy 

type ExecutionPolicy int32
const (
	ExecutionPolicy_EXECUTION_POLICY_UNSPECIFIED          ExecutionPolicy = 0
	ExecutionPolicy_EXECUTION_POLICY_DURABLE_FAIL_FAST    ExecutionPolicy = 1
	ExecutionPolicy_EXECUTION_POLICY_DURABLE_COMPENSATING ExecutionPolicy = 2
)

func (ExecutionPolicy) Descriptor 

func (ExecutionPolicy) Descriptor() protoreflect.EnumDescriptor

func (ExecutionPolicy) Enum 

func (x ExecutionPolicy) Enum() *ExecutionPolicy

func (ExecutionPolicy) EnumDescriptor deprecated 

func (ExecutionPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecutionPolicy.Descriptor instead.

func (ExecutionPolicy) Number 

func (x ExecutionPolicy) Number() protoreflect.EnumNumber

func (ExecutionPolicy) String 

func (x ExecutionPolicy) String() string

func (ExecutionPolicy) Type 

func (ExecutionPolicy) Type() protoreflect.EnumType

type ExecutionRequest 

type ExecutionRequest struct {
	RulesetName string     `protobuf:"bytes,1,opt,name=ruleset_name,json=rulesetName,proto3" json:"ruleset_name,omitempty"`
	Version     string     `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Facts       *anypb.Any `protobuf:"bytes,3,opt,name=facts,proto3" json:"facts,omitempty"`
	// Typed facts for checked execution. New clients must use this field.
	TypedFacts *structpb.Struct `protobuf:"bytes,11,opt,name=typed_facts,json=typedFacts,proto3" json:"typed_facts,omitempty"`
	// Only options.timeout_seconds is supported by effectusd.
	Options *ExecutionOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	TraceId string            `protobuf:"bytes,5,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// Unsupported by effectusd. Preserved for wire compatibility.
	//
	// Deprecated: Marked as deprecated in effectus/v1/execution.proto.
	SchemaValidation *SchemaValidation `protobuf:"bytes,6,opt,name=schema_validation,json=schemaValidation,proto3" json:"schema_validation,omitempty"`
	Namespace        string            `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"`
	IdempotencyKey   string            `protobuf:"bytes,8,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	WaitMode         ExecutionWaitMode `protobuf:"varint,9,opt,name=wait_mode,json=waitMode,proto3,enum=effectus.v1.ExecutionWaitMode" json:"wait_mode,omitempty"`
	// Optional exact generation constraint. A mismatch is rejected before admission.
	GenerationDigest string `protobuf:"bytes,10,opt,name=generation_digest,json=generationDigest,proto3" json:"generation_digest,omitempty"`
	// contains filtered or unexported fields
}

ExecutionRequest represents a request to execute rules

func (*ExecutionRequest) Descriptor deprecated 

func (*ExecutionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionRequest.ProtoReflect.Descriptor instead.

func (*ExecutionRequest) GetFacts 

func (x *ExecutionRequest) GetFacts() *anypb.Any

func (*ExecutionRequest) GetGenerationDigest 

func (x *ExecutionRequest) GetGenerationDigest() string

func (*ExecutionRequest) GetIdempotencyKey 

func (x *ExecutionRequest) GetIdempotencyKey() string

func (*ExecutionRequest) GetNamespace 

func (x *ExecutionRequest) GetNamespace() string

func (*ExecutionRequest) GetOptions 

func (x *ExecutionRequest) GetOptions() *ExecutionOptions

func (*ExecutionRequest) GetRulesetName 

func (x *ExecutionRequest) GetRulesetName() string

func (*ExecutionRequest) GetSchemaValidation deprecated 

func (x *ExecutionRequest) GetSchemaValidation() *SchemaValidation

Deprecated: Marked as deprecated in effectus/v1/execution.proto.

func (*ExecutionRequest) GetTraceId 

func (x *ExecutionRequest) GetTraceId() string

func (*ExecutionRequest) GetTypedFacts 

func (x *ExecutionRequest) GetTypedFacts() *structpb.Struct

func (*ExecutionRequest) GetVersion 

func (x *ExecutionRequest) GetVersion() string

func (*ExecutionRequest) GetWaitMode 

func (x *ExecutionRequest) GetWaitMode() ExecutionWaitMode

func (*ExecutionRequest) ProtoMessage 

func (*ExecutionRequest) ProtoMessage()

func (*ExecutionRequest) ProtoReflect 

func (x *ExecutionRequest) ProtoReflect() protoreflect.Message

func (*ExecutionRequest) Reset 

func (x *ExecutionRequest) Reset()

func (*ExecutionRequest) String 

func (x *ExecutionRequest) String() string

type ExecutionResponse 

type ExecutionResponse struct {
	Success     bool                   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Effects     []*TypedEffect         `protobuf:"bytes,2,rep,name=effects,proto3" json:"effects,omitempty"`
	ExecutionId string                 `protobuf:"bytes,3,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	StartTime   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Metadata    map[string]string      `` /* 143-byte string literal not displayed */
	Errors      []string               `protobuf:"bytes,7,rep,name=errors,proto3" json:"errors,omitempty"`
	Warnings    []string               `protobuf:"bytes,8,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// Schema information used in execution
	SchemaInfo *SchemaInfo `protobuf:"bytes,9,opt,name=schema_info,json=schemaInfo,proto3" json:"schema_info,omitempty"`
	// contains filtered or unexported fields
}

ExecutionResponse represents the response from rule execution

func (*ExecutionResponse) Descriptor deprecated 

func (*ExecutionResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionResponse.ProtoReflect.Descriptor instead.

func (*ExecutionResponse) GetEffects 

func (x *ExecutionResponse) GetEffects() []*TypedEffect

func (*ExecutionResponse) GetEndTime 

func (x *ExecutionResponse) GetEndTime() *timestamppb.Timestamp

func (*ExecutionResponse) GetErrors 

func (x *ExecutionResponse) GetErrors() []string

func (*ExecutionResponse) GetExecutionId 

func (x *ExecutionResponse) GetExecutionId() string

func (*ExecutionResponse) GetMetadata 

func (x *ExecutionResponse) GetMetadata() map[string]string

func (*ExecutionResponse) GetSchemaInfo 

func (x *ExecutionResponse) GetSchemaInfo() *SchemaInfo

func (*ExecutionResponse) GetStartTime 

func (x *ExecutionResponse) GetStartTime() *timestamppb.Timestamp

func (*ExecutionResponse) GetSuccess 

func (x *ExecutionResponse) GetSuccess() bool

func (*ExecutionResponse) GetWarnings 

func (x *ExecutionResponse) GetWarnings() []string

func (*ExecutionResponse) ProtoMessage 

func (*ExecutionResponse) ProtoMessage()

func (*ExecutionResponse) ProtoReflect 

func (x *ExecutionResponse) ProtoReflect() protoreflect.Message

func (*ExecutionResponse) Reset 

func (x *ExecutionResponse) Reset()

func (*ExecutionResponse) String 

func (x *ExecutionResponse) String() string

type ExecutionUpdate 

type ExecutionUpdate struct {
	ExecutionId     string                 `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	Phase           ExecutionPhase         `protobuf:"varint,2,opt,name=phase,proto3,enum=effectus.v1.ExecutionPhase" json:"phase,omitempty"`
	CurrentEffect   *TypedEffect           `protobuf:"bytes,3,opt,name=current_effect,json=currentEffect,proto3" json:"current_effect,omitempty"`
	ProgressPercent int32                  `protobuf:"varint,4,opt,name=progress_percent,json=progressPercent,proto3" json:"progress_percent,omitempty"`
	Message         string                 `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp       *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Schema compatibility status
	SchemaStatus *SchemaCompatibilityStatus `protobuf:"bytes,7,opt,name=schema_status,json=schemaStatus,proto3" json:"schema_status,omitempty"`
	// contains filtered or unexported fields
}

ExecutionUpdate provides streaming updates during execution

func (*ExecutionUpdate) Descriptor deprecated 

func (*ExecutionUpdate) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionUpdate.ProtoReflect.Descriptor instead.

func (*ExecutionUpdate) GetCurrentEffect 

func (x *ExecutionUpdate) GetCurrentEffect() *TypedEffect

func (*ExecutionUpdate) GetExecutionId 

func (x *ExecutionUpdate) GetExecutionId() string

func (*ExecutionUpdate) GetMessage 

func (x *ExecutionUpdate) GetMessage() string

func (*ExecutionUpdate) GetPhase 

func (x *ExecutionUpdate) GetPhase() ExecutionPhase

func (*ExecutionUpdate) GetProgressPercent 

func (x *ExecutionUpdate) GetProgressPercent() int32

func (*ExecutionUpdate) GetSchemaStatus 

func (x *ExecutionUpdate) GetSchemaStatus() *SchemaCompatibilityStatus

func (*ExecutionUpdate) GetTimestamp 

func (x *ExecutionUpdate) GetTimestamp() *timestamppb.Timestamp

func (*ExecutionUpdate) ProtoMessage 

func (*ExecutionUpdate) ProtoMessage()

func (*ExecutionUpdate) ProtoReflect 

func (x *ExecutionUpdate) ProtoReflect() protoreflect.Message

func (*ExecutionUpdate) Reset 

func (x *ExecutionUpdate) Reset()

func (*ExecutionUpdate) String 

func (x *ExecutionUpdate) String() string

type ExecutionWaitMode 

type ExecutionWaitMode int32
const (
	ExecutionWaitMode_EXECUTION_WAIT_MODE_UNSPECIFIED ExecutionWaitMode = 0
	ExecutionWaitMode_EXECUTION_WAIT_MODE_ACCEPTED    ExecutionWaitMode = 1
	ExecutionWaitMode_EXECUTION_WAIT_MODE_TERMINAL    ExecutionWaitMode = 2
)

func (ExecutionWaitMode) Descriptor 

func (ExecutionWaitMode) Descriptor() protoreflect.EnumDescriptor

func (ExecutionWaitMode) Enum 

func (x ExecutionWaitMode) Enum() *ExecutionWaitMode

func (ExecutionWaitMode) EnumDescriptor deprecated 

func (ExecutionWaitMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecutionWaitMode.Descriptor instead.

func (ExecutionWaitMode) Number 

func (x ExecutionWaitMode) Number() protoreflect.EnumNumber

func (ExecutionWaitMode) String 

func (x ExecutionWaitMode) String() string

func (ExecutionWaitMode) Type 

func (ExecutionWaitMode) Type() protoreflect.EnumType

type Expression 

type Expression struct {

	// Types that are valid to be assigned to Kind:
	//
	//	*Expression_Literal
	//	*Expression_FactPath
	//	*Expression_Unary
	//	*Expression_Binary
	//	*Expression_Call
	Kind isExpression_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*Expression) Descriptor deprecated 

func (*Expression) Descriptor() ([]byte, []int)

Deprecated: Use Expression.ProtoReflect.Descriptor instead.

func (*Expression) GetBinary 

func (x *Expression) GetBinary() *BinaryExpression

func (*Expression) GetCall 

func (x *Expression) GetCall() *FunctionCall

func (*Expression) GetFactPath 

func (x *Expression) GetFactPath() string

func (*Expression) GetKind 

func (x *Expression) GetKind() isExpression_Kind

func (*Expression) GetLiteral 

func (x *Expression) GetLiteral() *Literal

func (*Expression) GetUnary 

func (x *Expression) GetUnary() *UnaryExpression

func (*Expression) ProtoMessage 

func (*Expression) ProtoMessage()

func (*Expression) ProtoReflect 

func (x *Expression) ProtoReflect() protoreflect.Message

func (*Expression) Reset 

func (x *Expression) Reset()

func (*Expression) String 

func (x *Expression) String() string

type Expression_Binary 

type Expression_Binary struct {
	Binary *BinaryExpression `protobuf:"bytes,4,opt,name=binary,proto3,oneof"`
}

type Expression_Call 

type Expression_Call struct {
	Call *FunctionCall `protobuf:"bytes,5,opt,name=call,proto3,oneof"`
}

type Expression_FactPath 

type Expression_FactPath struct {
	FactPath string `protobuf:"bytes,2,opt,name=fact_path,json=factPath,proto3,oneof"`
}

type Expression_Literal 

type Expression_Literal struct {
	Literal *Literal `protobuf:"bytes,1,opt,name=literal,proto3,oneof"`
}

type Expression_Unary 

type Expression_Unary struct {
	Unary *UnaryExpression `protobuf:"bytes,3,opt,name=unary,proto3,oneof"`
}

type FactRegistryServiceClient 

type FactRegistryServiceClient interface {
	// RegisterFactSchema registers a new fact schema
	RegisterFactSchema(ctx context.Context, in *RegisterFactSchemaRequest, opts ...grpc.CallOption) (*RegisterFactSchemaResponse, error)
	// GetFactSchema retrieves a fact schema by name and version
	GetFactSchema(ctx context.Context, in *GetFactSchemaRequest, opts ...grpc.CallOption) (*GetFactSchemaResponse, error)
	// ListFactSchemas lists all registered fact schemas
	ListFactSchemas(ctx context.Context, in *ListFactSchemasRequest, opts ...grpc.CallOption) (*ListFactSchemasResponse, error)
	// ValidateFactData validates fact data against a schema
	ValidateFactData(ctx context.Context, in *ValidateFactDataRequest, opts ...grpc.CallOption) (*ValidateFactDataResponse, error)
	// CheckCompatibility checks if schema changes are backward compatible
	CheckCompatibility(ctx context.Context, in *CheckCompatibilityRequest, opts ...grpc.CallOption) (*CheckCompatibilityResponse, error)
}

FactRegistryServiceClient is the client API for FactRegistryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

FactRegistryService manages fact schemas and their evolution

func NewFactRegistryServiceClient 

func NewFactRegistryServiceClient(cc grpc.ClientConnInterface) FactRegistryServiceClient

type FactRegistryServiceServer 

type FactRegistryServiceServer interface {
	// RegisterFactSchema registers a new fact schema
	RegisterFactSchema(context.Context, *RegisterFactSchemaRequest) (*RegisterFactSchemaResponse, error)
	// GetFactSchema retrieves a fact schema by name and version
	GetFactSchema(context.Context, *GetFactSchemaRequest) (*GetFactSchemaResponse, error)
	// ListFactSchemas lists all registered fact schemas
	ListFactSchemas(context.Context, *ListFactSchemasRequest) (*ListFactSchemasResponse, error)
	// ValidateFactData validates fact data against a schema
	ValidateFactData(context.Context, *ValidateFactDataRequest) (*ValidateFactDataResponse, error)
	// CheckCompatibility checks if schema changes are backward compatible
	CheckCompatibility(context.Context, *CheckCompatibilityRequest) (*CheckCompatibilityResponse, error)
	// contains filtered or unexported methods
}

FactRegistryServiceServer is the server API for FactRegistryService service. All implementations must embed UnimplementedFactRegistryServiceServer for forward compatibility.

FactRegistryService manages fact schemas and their evolution

type FencingRequirement 

type FencingRequirement int32
const (
	FencingRequirement_FENCING_REQUIREMENT_UNSPECIFIED FencingRequirement = 0
	FencingRequirement_FENCING_REQUIREMENT_NONE        FencingRequirement = 1
	FencingRequirement_FENCING_REQUIREMENT_REQUIRED    FencingRequirement = 2
)

func (FencingRequirement) Descriptor 

func (FencingRequirement) Descriptor() protoreflect.EnumDescriptor

func (FencingRequirement) Enum 

func (x FencingRequirement) Enum() *FencingRequirement

func (FencingRequirement) EnumDescriptor deprecated 

func (FencingRequirement) EnumDescriptor() ([]byte, []int)

Deprecated: Use FencingRequirement.Descriptor instead.

func (FencingRequirement) Number 

func (x FencingRequirement) Number() protoreflect.EnumNumber

func (FencingRequirement) String 

func (x FencingRequirement) String() string

func (FencingRequirement) Type 

func (FencingRequirement) Type() protoreflect.EnumType

type FieldDescriptor 

type FieldDescriptor struct {
	Name        string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Number      int32     `protobuf:"varint,2,opt,name=number,proto3" json:"number,omitempty"`
	Type        FieldType `protobuf:"varint,3,opt,name=type,proto3,enum=effectus.v1.FieldType" json:"type,omitempty"`
	TypeName    string    `protobuf:"bytes,4,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"` // For message types
	Required    bool      `protobuf:"varint,5,opt,name=required,proto3" json:"required,omitempty"`
	Repeated    bool      `protobuf:"varint,6,opt,name=repeated,proto3" json:"repeated,omitempty"`
	Description string    `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// Field-level validation
	Constraints []*ValidationConstraint `protobuf:"bytes,8,rep,name=constraints,proto3" json:"constraints,omitempty"`
	// Default value
	DefaultValue *anypb.Any `protobuf:"bytes,9,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	// contains filtered or unexported fields
}

FieldDescriptor describes a field in a schema

func (*FieldDescriptor) Descriptor deprecated 

func (*FieldDescriptor) Descriptor() ([]byte, []int)

Deprecated: Use FieldDescriptor.ProtoReflect.Descriptor instead.

func (*FieldDescriptor) GetConstraints 

func (x *FieldDescriptor) GetConstraints() []*ValidationConstraint

func (*FieldDescriptor) GetDefaultValue 

func (x *FieldDescriptor) GetDefaultValue() *anypb.Any

func (*FieldDescriptor) GetDescription 

func (x *FieldDescriptor) GetDescription() string

func (*FieldDescriptor) GetName 

func (x *FieldDescriptor) GetName() string

func (*FieldDescriptor) GetNumber 

func (x *FieldDescriptor) GetNumber() int32

func (*FieldDescriptor) GetRepeated 

func (x *FieldDescriptor) GetRepeated() bool

func (*FieldDescriptor) GetRequired 

func (x *FieldDescriptor) GetRequired() bool

func (*FieldDescriptor) GetType 

func (x *FieldDescriptor) GetType() FieldType

func (*FieldDescriptor) GetTypeName 

func (x *FieldDescriptor) GetTypeName() string

func (*FieldDescriptor) ProtoMessage 

func (*FieldDescriptor) ProtoMessage()

func (*FieldDescriptor) ProtoReflect 

func (x *FieldDescriptor) ProtoReflect() protoreflect.Message

func (*FieldDescriptor) Reset 

func (x *FieldDescriptor) Reset()

func (*FieldDescriptor) String 

func (x *FieldDescriptor) String() string

type FieldType 

type FieldType int32

FieldType represents protobuf field types 

const (
	FieldType_FIELD_TYPE_UNSPECIFIED FieldType = 0
	FieldType_FIELD_TYPE_DOUBLE      FieldType = 1
	FieldType_FIELD_TYPE_FLOAT       FieldType = 2
	FieldType_FIELD_TYPE_INT64       FieldType = 3
	FieldType_FIELD_TYPE_UINT64      FieldType = 4
	FieldType_FIELD_TYPE_INT32       FieldType = 5
	FieldType_FIELD_TYPE_FIXED64     FieldType = 6
	FieldType_FIELD_TYPE_FIXED32     FieldType = 7
	FieldType_FIELD_TYPE_BOOL        FieldType = 8
	FieldType_FIELD_TYPE_STRING      FieldType = 9
	FieldType_FIELD_TYPE_GROUP       FieldType = 10
	FieldType_FIELD_TYPE_MESSAGE     FieldType = 11
	FieldType_FIELD_TYPE_BYTES       FieldType = 12
	FieldType_FIELD_TYPE_UINT32      FieldType = 13
	FieldType_FIELD_TYPE_ENUM        FieldType = 14
	FieldType_FIELD_TYPE_SFIXED32    FieldType = 15
	FieldType_FIELD_TYPE_SFIXED64    FieldType = 16
	FieldType_FIELD_TYPE_SINT32      FieldType = 17
	FieldType_FIELD_TYPE_SINT64      FieldType = 18
)

func (FieldType) Descriptor 

func (FieldType) Descriptor() protoreflect.EnumDescriptor

func (FieldType) Enum 

func (x FieldType) Enum() *FieldType

func (FieldType) EnumDescriptor deprecated 

func (FieldType) EnumDescriptor() ([]byte, []int)

Deprecated: Use FieldType.Descriptor instead.

func (FieldType) Number 

func (x FieldType) Number() protoreflect.EnumNumber

func (FieldType) String 

func (x FieldType) String() string

func (FieldType) Type 

func (FieldType) Type() protoreflect.EnumType

type FunctionCall 

type FunctionCall struct {
	Function  string        `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	Arguments []*Expression `protobuf:"bytes,2,rep,name=arguments,proto3" json:"arguments,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionCall) Descriptor deprecated 

func (*FunctionCall) Descriptor() ([]byte, []int)

Deprecated: Use FunctionCall.ProtoReflect.Descriptor instead.

func (*FunctionCall) GetArguments 

func (x *FunctionCall) GetArguments() []*Expression

func (*FunctionCall) GetFunction 

func (x *FunctionCall) GetFunction() string

func (*FunctionCall) ProtoMessage 

func (*FunctionCall) ProtoMessage()

func (*FunctionCall) ProtoReflect 

func (x *FunctionCall) ProtoReflect() protoreflect.Message

func (*FunctionCall) Reset 

func (x *FunctionCall) Reset()

func (*FunctionCall) String 

func (x *FunctionCall) String() string

type GenerateVerbCodeRequest 

type GenerateVerbCodeRequest struct {
	VerbName         string               `protobuf:"bytes,1,opt,name=verb_name,json=verbName,proto3" json:"verb_name,omitempty"`
	InterfaceVersion string               `protobuf:"bytes,2,opt,name=interface_version,json=interfaceVersion,proto3" json:"interface_version,omitempty"`
	Target           CodeGenerationTarget `protobuf:"varint,3,opt,name=target,proto3,enum=effectus.v1.CodeGenerationTarget" json:"target,omitempty"`
	Options          map[string]string    `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GenerateVerbCodeRequest) Descriptor deprecated 

func (*GenerateVerbCodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use GenerateVerbCodeRequest.ProtoReflect.Descriptor instead.

func (*GenerateVerbCodeRequest) GetInterfaceVersion 

func (x *GenerateVerbCodeRequest) GetInterfaceVersion() string

func (*GenerateVerbCodeRequest) GetOptions 

func (x *GenerateVerbCodeRequest) GetOptions() map[string]string

func (*GenerateVerbCodeRequest) GetTarget 

func (x *GenerateVerbCodeRequest) GetTarget() CodeGenerationTarget

func (*GenerateVerbCodeRequest) GetVerbName 

func (x *GenerateVerbCodeRequest) GetVerbName() string

func (*GenerateVerbCodeRequest) ProtoMessage 

func (*GenerateVerbCodeRequest) ProtoMessage()

func (*GenerateVerbCodeRequest) ProtoReflect 

func (x *GenerateVerbCodeRequest) ProtoReflect() protoreflect.Message

func (*GenerateVerbCodeRequest) Reset 

func (x *GenerateVerbCodeRequest) Reset()

func (*GenerateVerbCodeRequest) String 

func (x *GenerateVerbCodeRequest) String() string

type GenerateVerbCodeResponse 

type GenerateVerbCodeResponse struct {
	Success        bool              `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	GeneratedFiles map[string]string `` // filename -> content
	/* 177-byte string literal not displayed */
	Errors   []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	Warnings []string `protobuf:"bytes,4,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateVerbCodeResponse) Descriptor deprecated 

func (*GenerateVerbCodeResponse) Descriptor() ([]byte, []int)

Deprecated: Use GenerateVerbCodeResponse.ProtoReflect.Descriptor instead.

func (*GenerateVerbCodeResponse) GetErrors 

func (x *GenerateVerbCodeResponse) GetErrors() []string

func (*GenerateVerbCodeResponse) GetGeneratedFiles 

func (x *GenerateVerbCodeResponse) GetGeneratedFiles() map[string]string

func (*GenerateVerbCodeResponse) GetSuccess 

func (x *GenerateVerbCodeResponse) GetSuccess() bool

func (*GenerateVerbCodeResponse) GetWarnings 

func (x *GenerateVerbCodeResponse) GetWarnings() []string

func (*GenerateVerbCodeResponse) ProtoMessage 

func (*GenerateVerbCodeResponse) ProtoMessage()

func (*GenerateVerbCodeResponse) ProtoReflect 

func (x *GenerateVerbCodeResponse) ProtoReflect() protoreflect.Message

func (*GenerateVerbCodeResponse) Reset 

func (x *GenerateVerbCodeResponse) Reset()

func (*GenerateVerbCodeResponse) String 

func (x *GenerateVerbCodeResponse) String() string

type GetFactSchemaRequest 

type GetFactSchemaRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFactSchemaRequest) Descriptor deprecated 

func (*GetFactSchemaRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetFactSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetFactSchemaRequest) GetName 

func (x *GetFactSchemaRequest) GetName() string

func (*GetFactSchemaRequest) GetVersion 

func (x *GetFactSchemaRequest) GetVersion() string

func (*GetFactSchemaRequest) ProtoMessage 

func (*GetFactSchemaRequest) ProtoMessage()

func (*GetFactSchemaRequest) ProtoReflect 

func (x *GetFactSchemaRequest) ProtoReflect() protoreflect.Message

func (*GetFactSchemaRequest) Reset 

func (x *GetFactSchemaRequest) Reset()

func (*GetFactSchemaRequest) String 

func (x *GetFactSchemaRequest) String() string

type GetFactSchemaResponse 

type GetFactSchemaResponse struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Found  bool    `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFactSchemaResponse) Descriptor deprecated 

func (*GetFactSchemaResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetFactSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetFactSchemaResponse) GetFound 

func (x *GetFactSchemaResponse) GetFound() bool

func (*GetFactSchemaResponse) GetSchema 

func (x *GetFactSchemaResponse) GetSchema() *Schema

func (*GetFactSchemaResponse) ProtoMessage 

func (*GetFactSchemaResponse) ProtoMessage()

func (*GetFactSchemaResponse) ProtoReflect 

func (x *GetFactSchemaResponse) ProtoReflect() protoreflect.Message

func (*GetFactSchemaResponse) Reset 

func (x *GetFactSchemaResponse) Reset()

func (*GetFactSchemaResponse) String 

func (x *GetFactSchemaResponse) String() string

type GetVerbInterfaceRequest 

type GetVerbInterfaceRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Optional: latest if not specified
	// contains filtered or unexported fields
}

func (*GetVerbInterfaceRequest) Descriptor deprecated 

func (*GetVerbInterfaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetVerbInterfaceRequest.ProtoReflect.Descriptor instead.

func (*GetVerbInterfaceRequest) GetName 

func (x *GetVerbInterfaceRequest) GetName() string

func (*GetVerbInterfaceRequest) GetVersion 

func (x *GetVerbInterfaceRequest) GetVersion() string

func (*GetVerbInterfaceRequest) ProtoMessage 

func (*GetVerbInterfaceRequest) ProtoMessage()

func (*GetVerbInterfaceRequest) ProtoReflect 

func (x *GetVerbInterfaceRequest) ProtoReflect() protoreflect.Message

func (*GetVerbInterfaceRequest) Reset 

func (x *GetVerbInterfaceRequest) Reset()

func (*GetVerbInterfaceRequest) String 

func (x *GetVerbInterfaceRequest) String() string

type GetVerbInterfaceResponse 

type GetVerbInterfaceResponse struct {
	VerbInterface        *VerbInterface `protobuf:"bytes,1,opt,name=verb_interface,json=verbInterface,proto3" json:"verb_interface,omitempty"`
	CompatibleVersions   []string       `protobuf:"bytes,2,rep,name=compatible_versions,json=compatibleVersions,proto3" json:"compatible_versions,omitempty"`
	BreakingChangesSince []string       `protobuf:"bytes,3,rep,name=breaking_changes_since,json=breakingChangesSince,proto3" json:"breaking_changes_since,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVerbInterfaceResponse) Descriptor deprecated 

func (*GetVerbInterfaceResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetVerbInterfaceResponse.ProtoReflect.Descriptor instead.

func (*GetVerbInterfaceResponse) GetBreakingChangesSince 

func (x *GetVerbInterfaceResponse) GetBreakingChangesSince() []string

func (*GetVerbInterfaceResponse) GetCompatibleVersions 

func (x *GetVerbInterfaceResponse) GetCompatibleVersions() []string

func (*GetVerbInterfaceResponse) GetVerbInterface 

func (x *GetVerbInterfaceResponse) GetVerbInterface() *VerbInterface

func (*GetVerbInterfaceResponse) ProtoMessage 

func (*GetVerbInterfaceResponse) ProtoMessage()

func (*GetVerbInterfaceResponse) ProtoReflect 

func (x *GetVerbInterfaceResponse) ProtoReflect() protoreflect.Message

func (*GetVerbInterfaceResponse) Reset 

func (x *GetVerbInterfaceResponse) Reset()

func (*GetVerbInterfaceResponse) String 

func (x *GetVerbInterfaceResponse) String() string

type IdempotencyPolicy 

type IdempotencyPolicy int32
const (
	IdempotencyPolicy_IDEMPOTENCY_POLICY_UNSPECIFIED     IdempotencyPolicy = 0
	IdempotencyPolicy_IDEMPOTENCY_POLICY_NONE            IdempotencyPolicy = 1
	IdempotencyPolicy_IDEMPOTENCY_POLICY_KEY_REQUIRED    IdempotencyPolicy = 2
	IdempotencyPolicy_IDEMPOTENCY_POLICY_SINK_GUARANTEED IdempotencyPolicy = 3
)

func (IdempotencyPolicy) Descriptor 

func (IdempotencyPolicy) Descriptor() protoreflect.EnumDescriptor

func (IdempotencyPolicy) Enum 

func (x IdempotencyPolicy) Enum() *IdempotencyPolicy

func (IdempotencyPolicy) EnumDescriptor deprecated 

func (IdempotencyPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use IdempotencyPolicy.Descriptor instead.

func (IdempotencyPolicy) Number 

func (x IdempotencyPolicy) Number() protoreflect.EnumNumber

func (IdempotencyPolicy) String 

func (x IdempotencyPolicy) String() string

func (IdempotencyPolicy) Type 

func (IdempotencyPolicy) Type() protoreflect.EnumType

type InterfaceEvolution 

type InterfaceEvolution struct {
	InterfaceName        string                        `protobuf:"bytes,1,opt,name=interface_name,json=interfaceName,proto3" json:"interface_name,omitempty"`
	Versions             []string                      `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	VersionCompatibility map[string]*CompatibilityInfo `` /* 195-byte string literal not displayed */
	DeprecatedVersions   []string                      `protobuf:"bytes,4,rep,name=deprecated_versions,json=deprecatedVersions,proto3" json:"deprecated_versions,omitempty"`
	RecommendedVersion   string                        `protobuf:"bytes,5,opt,name=recommended_version,json=recommendedVersion,proto3" json:"recommended_version,omitempty"`
	// contains filtered or unexported fields
}

InterfaceEvolution tracks the evolution of a verb interface over time

func (*InterfaceEvolution) Descriptor deprecated 

func (*InterfaceEvolution) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceEvolution.ProtoReflect.Descriptor instead.

func (*InterfaceEvolution) GetDeprecatedVersions 

func (x *InterfaceEvolution) GetDeprecatedVersions() []string

func (*InterfaceEvolution) GetInterfaceName 

func (x *InterfaceEvolution) GetInterfaceName() string

func (*InterfaceEvolution) GetRecommendedVersion 

func (x *InterfaceEvolution) GetRecommendedVersion() string

func (*InterfaceEvolution) GetVersionCompatibility 

func (x *InterfaceEvolution) GetVersionCompatibility() map[string]*CompatibilityInfo

func (*InterfaceEvolution) GetVersions 

func (x *InterfaceEvolution) GetVersions() []string

func (*InterfaceEvolution) ProtoMessage 

func (*InterfaceEvolution) ProtoMessage()

func (*InterfaceEvolution) ProtoReflect 

func (x *InterfaceEvolution) ProtoReflect() protoreflect.Message

func (*InterfaceEvolution) Reset 

func (x *InterfaceEvolution) Reset()

func (*InterfaceEvolution) String 

func (x *InterfaceEvolution) String() string

type ListFactSchemasRequest 

type ListFactSchemasRequest struct {
	NamePrefix    string `protobuf:"bytes,1,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"`
	VersionFilter string `protobuf:"bytes,2,opt,name=version_filter,json=versionFilter,proto3" json:"version_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFactSchemasRequest) Descriptor deprecated 

func (*ListFactSchemasRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListFactSchemasRequest.ProtoReflect.Descriptor instead.

func (*ListFactSchemasRequest) GetNamePrefix 

func (x *ListFactSchemasRequest) GetNamePrefix() string

func (*ListFactSchemasRequest) GetVersionFilter 

func (x *ListFactSchemasRequest) GetVersionFilter() string

func (*ListFactSchemasRequest) ProtoMessage 

func (*ListFactSchemasRequest) ProtoMessage()

func (*ListFactSchemasRequest) ProtoReflect 

func (x *ListFactSchemasRequest) ProtoReflect() protoreflect.Message

func (*ListFactSchemasRequest) Reset 

func (x *ListFactSchemasRequest) Reset()

func (*ListFactSchemasRequest) String 

func (x *ListFactSchemasRequest) String() string

type ListFactSchemasResponse 

type ListFactSchemasResponse struct {
	Schemas []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFactSchemasResponse) Descriptor deprecated 

func (*ListFactSchemasResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListFactSchemasResponse.ProtoReflect.Descriptor instead.

func (*ListFactSchemasResponse) GetSchemas 

func (x *ListFactSchemasResponse) GetSchemas() []*Schema

func (*ListFactSchemasResponse) ProtoMessage 

func (*ListFactSchemasResponse) ProtoMessage()

func (*ListFactSchemasResponse) ProtoReflect 

func (x *ListFactSchemasResponse) ProtoReflect() protoreflect.Message

func (*ListFactSchemasResponse) Reset 

func (x *ListFactSchemasResponse) Reset()

func (*ListFactSchemasResponse) String 

func (x *ListFactSchemasResponse) String() string

type ListRulesetsRequest 

type ListRulesetsRequest struct {

	// Filtering options
	NameFilter       string   `protobuf:"bytes,1,opt,name=name_filter,json=nameFilter,proto3" json:"name_filter,omitempty"`
	VersionFilter    string   `protobuf:"bytes,2,opt,name=version_filter,json=versionFilter,proto3" json:"version_filter,omitempty"`
	CapabilityFilter []string `protobuf:"bytes,3,rep,name=capability_filter,json=capabilityFilter,proto3" json:"capability_filter,omitempty"`
	// Schema version constraints
	MinSchemaVersion string `protobuf:"bytes,4,opt,name=min_schema_version,json=minSchemaVersion,proto3" json:"min_schema_version,omitempty"`
	MaxSchemaVersion string `protobuf:"bytes,5,opt,name=max_schema_version,json=maxSchemaVersion,proto3" json:"max_schema_version,omitempty"`
	// contains filtered or unexported fields
}

ListRulesetsRequest requests all registered rulesets

func (*ListRulesetsRequest) Descriptor deprecated 

func (*ListRulesetsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListRulesetsRequest.ProtoReflect.Descriptor instead.

func (*ListRulesetsRequest) GetCapabilityFilter 

func (x *ListRulesetsRequest) GetCapabilityFilter() []string

func (*ListRulesetsRequest) GetMaxSchemaVersion 

func (x *ListRulesetsRequest) GetMaxSchemaVersion() string

func (*ListRulesetsRequest) GetMinSchemaVersion 

func (x *ListRulesetsRequest) GetMinSchemaVersion() string

func (*ListRulesetsRequest) GetNameFilter 

func (x *ListRulesetsRequest) GetNameFilter() string

func (*ListRulesetsRequest) GetVersionFilter 

func (x *ListRulesetsRequest) GetVersionFilter() string

func (*ListRulesetsRequest) ProtoMessage 

func (*ListRulesetsRequest) ProtoMessage()

func (*ListRulesetsRequest) ProtoReflect 

func (x *ListRulesetsRequest) ProtoReflect() protoreflect.Message

func (*ListRulesetsRequest) Reset 

func (x *ListRulesetsRequest) Reset()

func (*ListRulesetsRequest) String 

func (x *ListRulesetsRequest) String() string

type ListRulesetsResponse 

type ListRulesetsResponse struct {
	Rulesets []*RulesetInfo `protobuf:"bytes,1,rep,name=rulesets,proto3" json:"rulesets,omitempty"`
	// Schema registry information
	SchemaRegistry *SchemaRegistryInfo `protobuf:"bytes,2,opt,name=schema_registry,json=schemaRegistry,proto3" json:"schema_registry,omitempty"`
	// contains filtered or unexported fields
}

ListRulesetsResponse returns all registered rulesets

func (*ListRulesetsResponse) Descriptor deprecated 

func (*ListRulesetsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListRulesetsResponse.ProtoReflect.Descriptor instead.

func (*ListRulesetsResponse) GetRulesets 

func (x *ListRulesetsResponse) GetRulesets() []*RulesetInfo

func (*ListRulesetsResponse) GetSchemaRegistry 

func (x *ListRulesetsResponse) GetSchemaRegistry() *SchemaRegistryInfo

func (*ListRulesetsResponse) ProtoMessage 

func (*ListRulesetsResponse) ProtoMessage()

func (*ListRulesetsResponse) ProtoReflect 

func (x *ListRulesetsResponse) ProtoReflect() protoreflect.Message

func (*ListRulesetsResponse) Reset 

func (x *ListRulesetsResponse) Reset()

func (*ListRulesetsResponse) String 

func (x *ListRulesetsResponse) String() string

type ListVerbInterfacesRequest 

type ListVerbInterfacesRequest struct {
	NameFilter        string   `protobuf:"bytes,1,opt,name=name_filter,json=nameFilter,proto3" json:"name_filter,omitempty"`
	VersionFilter     string   `protobuf:"bytes,2,opt,name=version_filter,json=versionFilter,proto3" json:"version_filter,omitempty"`
	CapabilityFilter  []string `protobuf:"bytes,3,rep,name=capability_filter,json=capabilityFilter,proto3" json:"capability_filter,omitempty"`
	TagFilter         []string `protobuf:"bytes,4,rep,name=tag_filter,json=tagFilter,proto3" json:"tag_filter,omitempty"`
	IncludeDeprecated bool     `protobuf:"varint,5,opt,name=include_deprecated,json=includeDeprecated,proto3" json:"include_deprecated,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVerbInterfacesRequest) Descriptor deprecated 

func (*ListVerbInterfacesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListVerbInterfacesRequest.ProtoReflect.Descriptor instead.

func (*ListVerbInterfacesRequest) GetCapabilityFilter 

func (x *ListVerbInterfacesRequest) GetCapabilityFilter() []string

func (*ListVerbInterfacesRequest) GetIncludeDeprecated 

func (x *ListVerbInterfacesRequest) GetIncludeDeprecated() bool

func (*ListVerbInterfacesRequest) GetNameFilter 

func (x *ListVerbInterfacesRequest) GetNameFilter() string

func (*ListVerbInterfacesRequest) GetTagFilter 

func (x *ListVerbInterfacesRequest) GetTagFilter() []string

func (*ListVerbInterfacesRequest) GetVersionFilter 

func (x *ListVerbInterfacesRequest) GetVersionFilter() string

func (*ListVerbInterfacesRequest) ProtoMessage 

func (*ListVerbInterfacesRequest) ProtoMessage()

func (*ListVerbInterfacesRequest) ProtoReflect 

func (x *ListVerbInterfacesRequest) ProtoReflect() protoreflect.Message

func (*ListVerbInterfacesRequest) Reset 

func (x *ListVerbInterfacesRequest) Reset()

func (*ListVerbInterfacesRequest) String 

func (x *ListVerbInterfacesRequest) String() string

type ListVerbInterfacesResponse 

type ListVerbInterfacesResponse struct {
	VerbInterfaces     []*VerbInterface  `protobuf:"bytes,1,rep,name=verb_interfaces,json=verbInterfaces,proto3" json:"verb_interfaces,omitempty"`
	LatestVersions     map[string]string `` /* 177-byte string literal not displayed */
	DeprecatedVersions []string          `protobuf:"bytes,3,rep,name=deprecated_versions,json=deprecatedVersions,proto3" json:"deprecated_versions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVerbInterfacesResponse) Descriptor deprecated 

func (*ListVerbInterfacesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListVerbInterfacesResponse.ProtoReflect.Descriptor instead.

func (*ListVerbInterfacesResponse) GetDeprecatedVersions 

func (x *ListVerbInterfacesResponse) GetDeprecatedVersions() []string

func (*ListVerbInterfacesResponse) GetLatestVersions 

func (x *ListVerbInterfacesResponse) GetLatestVersions() map[string]string

func (*ListVerbInterfacesResponse) GetVerbInterfaces 

func (x *ListVerbInterfacesResponse) GetVerbInterfaces() []*VerbInterface

func (*ListVerbInterfacesResponse) ProtoMessage 

func (*ListVerbInterfacesResponse) ProtoMessage()

func (*ListVerbInterfacesResponse) ProtoReflect 

func (x *ListVerbInterfacesResponse) ProtoReflect() protoreflect.Message

func (*ListVerbInterfacesResponse) Reset 

func (x *ListVerbInterfacesResponse) Reset()

func (*ListVerbInterfacesResponse) String 

func (x *ListVerbInterfacesResponse) String() string

type Literal 

type Literal struct {

	// Types that are valid to be assigned to Kind:
	//
	//	*Literal_Null
	//	*Literal_BoolValue
	//	*Literal_IntValue
	//	*Literal_DoubleValue
	//	*Literal_StringValue
	//	*Literal_BytesValue
	//	*Literal_ListValue
	//	*Literal_ObjectValue
	Kind isLiteral_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*Literal) Descriptor deprecated 

func (*Literal) Descriptor() ([]byte, []int)

Deprecated: Use Literal.ProtoReflect.Descriptor instead.

func (*Literal) GetBoolValue 

func (x *Literal) GetBoolValue() bool

func (*Literal) GetBytesValue 

func (x *Literal) GetBytesValue() []byte

func (*Literal) GetDoubleValue 

func (x *Literal) GetDoubleValue() float64

func (*Literal) GetIntValue 

func (x *Literal) GetIntValue() int64

func (*Literal) GetKind 

func (x *Literal) GetKind() isLiteral_Kind

func (*Literal) GetListValue 

func (x *Literal) GetListValue() *LiteralList

func (*Literal) GetNull 

func (x *Literal) GetNull() NullValue

func (*Literal) GetObjectValue 

func (x *Literal) GetObjectValue() *LiteralObject

func (*Literal) GetStringValue 

func (x *Literal) GetStringValue() string

func (*Literal) ProtoMessage 

func (*Literal) ProtoMessage()

func (*Literal) ProtoReflect 

func (x *Literal) ProtoReflect() protoreflect.Message

func (*Literal) Reset 

func (x *Literal) Reset()

func (*Literal) String 

func (x *Literal) String() string

type LiteralField 

type LiteralField struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value *Literal `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LiteralField) Descriptor deprecated 

func (*LiteralField) Descriptor() ([]byte, []int)

Deprecated: Use LiteralField.ProtoReflect.Descriptor instead.

func (*LiteralField) GetName 

func (x *LiteralField) GetName() string

func (*LiteralField) GetValue 

func (x *LiteralField) GetValue() *Literal

func (*LiteralField) ProtoMessage 

func (*LiteralField) ProtoMessage()

func (*LiteralField) ProtoReflect 

func (x *LiteralField) ProtoReflect() protoreflect.Message

func (*LiteralField) Reset 

func (x *LiteralField) Reset()

func (*LiteralField) String 

func (x *LiteralField) String() string

type LiteralList 

type LiteralList struct {
	Values []*Literal `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LiteralList) Descriptor deprecated 

func (*LiteralList) Descriptor() ([]byte, []int)

Deprecated: Use LiteralList.ProtoReflect.Descriptor instead.

func (*LiteralList) GetValues 

func (x *LiteralList) GetValues() []*Literal

func (*LiteralList) ProtoMessage 

func (*LiteralList) ProtoMessage()

func (*LiteralList) ProtoReflect 

func (x *LiteralList) ProtoReflect() protoreflect.Message

func (*LiteralList) Reset 

func (x *LiteralList) Reset()

func (*LiteralList) String 

func (x *LiteralList) String() string

type LiteralObject 

type LiteralObject struct {

	// Fields are ordered lexicographically by name in checked artifacts.
	Fields []*LiteralField `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*LiteralObject) Descriptor deprecated 

func (*LiteralObject) Descriptor() ([]byte, []int)

Deprecated: Use LiteralObject.ProtoReflect.Descriptor instead.

func (*LiteralObject) GetFields 

func (x *LiteralObject) GetFields() []*LiteralField

func (*LiteralObject) ProtoMessage 

func (*LiteralObject) ProtoMessage()

func (*LiteralObject) ProtoReflect 

func (x *LiteralObject) ProtoReflect() protoreflect.Message

func (*LiteralObject) Reset 

func (x *LiteralObject) Reset()

func (*LiteralObject) String 

func (x *LiteralObject) String() string

type Literal_BoolValue 

type Literal_BoolValue struct {
	BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type Literal_BytesValue 

type Literal_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,6,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type Literal_DoubleValue 

type Literal_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type Literal_IntValue 

type Literal_IntValue struct {
	IntValue int64 `protobuf:"zigzag64,3,opt,name=int_value,json=intValue,proto3,oneof"`
}

type Literal_ListValue 

type Literal_ListValue struct {
	ListValue *LiteralList `protobuf:"bytes,7,opt,name=list_value,json=listValue,proto3,oneof"`
}

type Literal_Null 

type Literal_Null struct {
	Null NullValue `protobuf:"varint,1,opt,name=null,proto3,enum=effectus.v1.NullValue,oneof"`
}

type Literal_ObjectValue 

type Literal_ObjectValue struct {
	ObjectValue *LiteralObject `protobuf:"bytes,8,opt,name=object_value,json=objectValue,proto3,oneof"`
}

type Literal_StringValue 

type Literal_StringValue struct {
	StringValue string `protobuf:"bytes,5,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type NullValue 

type NullValue int32
const (
	NullValue_NULL_VALUE_UNSPECIFIED NullValue = 0
	NullValue_NULL_VALUE_NULL        NullValue = 1
)

func (NullValue) Descriptor 

func (NullValue) Descriptor() protoreflect.EnumDescriptor

func (NullValue) Enum 

func (x NullValue) Enum() *NullValue

func (NullValue) EnumDescriptor deprecated 

func (NullValue) EnumDescriptor() ([]byte, []int)

Deprecated: Use NullValue.Descriptor instead.

func (NullValue) Number 

func (x NullValue) Number() protoreflect.EnumNumber

func (NullValue) String 

func (x NullValue) String() string

func (NullValue) Type 

func (NullValue) Type() protoreflect.EnumType

type Plan 

type Plan struct {
	Id              string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SourceDialect   SourceDialect   `` /* 132-byte string literal not displayed */
	SourceOrder     uint32          `protobuf:"varint,3,opt,name=source_order,json=sourceOrder,proto3" json:"source_order,omitempty"`
	Priority        int32           `protobuf:"zigzag32,4,opt,name=priority,proto3" json:"priority,omitempty"`
	Predicate       *Predicate      `protobuf:"bytes,5,opt,name=predicate,proto3" json:"predicate,omitempty"`
	ExecutionPolicy ExecutionPolicy `` /* 140-byte string literal not displayed */
	Steps           []*Step         `protobuf:"bytes,7,rep,name=steps,proto3" json:"steps,omitempty"`
	// contains filtered or unexported fields
}

func (*Plan) Descriptor deprecated 

func (*Plan) Descriptor() ([]byte, []int)

Deprecated: Use Plan.ProtoReflect.Descriptor instead.

func (*Plan) GetExecutionPolicy 

func (x *Plan) GetExecutionPolicy() ExecutionPolicy

func (*Plan) GetId 

func (x *Plan) GetId() string

func (*Plan) GetPredicate 

func (x *Plan) GetPredicate() *Predicate

func (*Plan) GetPriority 

func (x *Plan) GetPriority() int32

func (*Plan) GetSourceDialect 

func (x *Plan) GetSourceDialect() SourceDialect

func (*Plan) GetSourceOrder 

func (x *Plan) GetSourceOrder() uint32

func (*Plan) GetSteps 

func (x *Plan) GetSteps() []*Step

func (*Plan) ProtoMessage 

func (*Plan) ProtoMessage()

func (*Plan) ProtoReflect 

func (x *Plan) ProtoReflect() protoreflect.Message

func (*Plan) Reset 

func (x *Plan) Reset()

func (*Plan) String 

func (x *Plan) String() string

type Predicate 

type Predicate struct {
	Expression *Expression `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*Predicate) Descriptor deprecated 

func (*Predicate) Descriptor() ([]byte, []int)

Deprecated: Use Predicate.ProtoReflect.Descriptor instead.

func (*Predicate) GetExpression 

func (x *Predicate) GetExpression() *Expression

func (*Predicate) ProtoMessage 

func (*Predicate) ProtoMessage()

func (*Predicate) ProtoReflect 

func (x *Predicate) ProtoReflect() protoreflect.Message

func (*Predicate) Reset 

func (x *Predicate) Reset()

func (*Predicate) String 

func (x *Predicate) String() string

type RateLimits 

type RateLimits struct {
	CallsPerSecond int32 `protobuf:"varint,1,opt,name=calls_per_second,json=callsPerSecond,proto3" json:"calls_per_second,omitempty"`
	CallsPerMinute int32 `protobuf:"varint,2,opt,name=calls_per_minute,json=callsPerMinute,proto3" json:"calls_per_minute,omitempty"`
	CallsPerHour   int32 `protobuf:"varint,3,opt,name=calls_per_hour,json=callsPerHour,proto3" json:"calls_per_hour,omitempty"`
	CallsPerDay    int32 `protobuf:"varint,4,opt,name=calls_per_day,json=callsPerDay,proto3" json:"calls_per_day,omitempty"`
	// Burst limits
	BurstCapacity int32 `protobuf:"varint,5,opt,name=burst_capacity,json=burstCapacity,proto3" json:"burst_capacity,omitempty"`
	// contains filtered or unexported fields
}

RateLimits define rate limiting constraints

func (*RateLimits) Descriptor deprecated 

func (*RateLimits) Descriptor() ([]byte, []int)

Deprecated: Use RateLimits.ProtoReflect.Descriptor instead.

func (*RateLimits) GetBurstCapacity 

func (x *RateLimits) GetBurstCapacity() int32

func (*RateLimits) GetCallsPerDay 

func (x *RateLimits) GetCallsPerDay() int32

func (*RateLimits) GetCallsPerHour 

func (x *RateLimits) GetCallsPerHour() int32

func (*RateLimits) GetCallsPerMinute 

func (x *RateLimits) GetCallsPerMinute() int32

func (*RateLimits) GetCallsPerSecond 

func (x *RateLimits) GetCallsPerSecond() int32

func (*RateLimits) ProtoMessage 

func (*RateLimits) ProtoMessage()

func (*RateLimits) ProtoReflect 

func (x *RateLimits) ProtoReflect() protoreflect.Message

func (*RateLimits) Reset 

func (x *RateLimits) Reset()

func (*RateLimits) String 

func (x *RateLimits) String() string

type RegisterFactSchemaRequest 

type RegisterFactSchemaRequest struct {
	Schema      *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	ForceUpdate bool    `protobuf:"varint,2,opt,name=force_update,json=forceUpdate,proto3" json:"force_update,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterFactSchemaRequest) Descriptor deprecated 

func (*RegisterFactSchemaRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterFactSchemaRequest.ProtoReflect.Descriptor instead.

func (*RegisterFactSchemaRequest) GetForceUpdate 

func (x *RegisterFactSchemaRequest) GetForceUpdate() bool

func (*RegisterFactSchemaRequest) GetSchema 

func (x *RegisterFactSchemaRequest) GetSchema() *Schema

func (*RegisterFactSchemaRequest) ProtoMessage 

func (*RegisterFactSchemaRequest) ProtoMessage()

func (*RegisterFactSchemaRequest) ProtoReflect 

func (x *RegisterFactSchemaRequest) ProtoReflect() protoreflect.Message

func (*RegisterFactSchemaRequest) Reset 

func (x *RegisterFactSchemaRequest) Reset()

func (*RegisterFactSchemaRequest) String 

func (x *RegisterFactSchemaRequest) String() string

type RegisterFactSchemaResponse 

type RegisterFactSchemaResponse struct {
	Success  bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message  string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Warnings []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterFactSchemaResponse) Descriptor deprecated 

func (*RegisterFactSchemaResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterFactSchemaResponse.ProtoReflect.Descriptor instead.

func (*RegisterFactSchemaResponse) GetMessage 

func (x *RegisterFactSchemaResponse) GetMessage() string

func (*RegisterFactSchemaResponse) GetSuccess 

func (x *RegisterFactSchemaResponse) GetSuccess() bool

func (*RegisterFactSchemaResponse) GetWarnings 

func (x *RegisterFactSchemaResponse) GetWarnings() []string

func (*RegisterFactSchemaResponse) ProtoMessage 

func (*RegisterFactSchemaResponse) ProtoMessage()

func (*RegisterFactSchemaResponse) ProtoReflect 

func (x *RegisterFactSchemaResponse) ProtoReflect() protoreflect.Message

func (*RegisterFactSchemaResponse) Reset 

func (x *RegisterFactSchemaResponse) Reset()

func (*RegisterFactSchemaResponse) String 

func (x *RegisterFactSchemaResponse) String() string

type RegisterRulesetRequest 

type RegisterRulesetRequest struct {
	Ruleset *CompiledRuleset `protobuf:"bytes,1,opt,name=ruleset,proto3" json:"ruleset,omitempty"`
	// Schema validation options
	ValidateSchemaCompatibility bool `` /* 145-byte string literal not displayed */
	ForceSchemaUpdate           bool `protobuf:"varint,3,opt,name=force_schema_update,json=forceSchemaUpdate,proto3" json:"force_schema_update,omitempty"`
	// contains filtered or unexported fields
}

RegisterRulesetRequest registers a new ruleset

func (*RegisterRulesetRequest) Descriptor deprecated 

func (*RegisterRulesetRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterRulesetRequest.ProtoReflect.Descriptor instead.

func (*RegisterRulesetRequest) GetForceSchemaUpdate 

func (x *RegisterRulesetRequest) GetForceSchemaUpdate() bool

func (*RegisterRulesetRequest) GetRuleset 

func (x *RegisterRulesetRequest) GetRuleset() *CompiledRuleset

func (*RegisterRulesetRequest) GetValidateSchemaCompatibility 

func (x *RegisterRulesetRequest) GetValidateSchemaCompatibility() bool

func (*RegisterRulesetRequest) ProtoMessage 

func (*RegisterRulesetRequest) ProtoMessage()

func (*RegisterRulesetRequest) ProtoReflect 

func (x *RegisterRulesetRequest) ProtoReflect() protoreflect.Message

func (*RegisterRulesetRequest) Reset 

func (x *RegisterRulesetRequest) Reset()

func (*RegisterRulesetRequest) String 

func (x *RegisterRulesetRequest) String() string

type RegisterRulesetResponse 

type RegisterRulesetResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Schema validation results
	SchemaWarnings  []string `protobuf:"bytes,3,rep,name=schema_warnings,json=schemaWarnings,proto3" json:"schema_warnings,omitempty"`
	AssignedVersion string   `protobuf:"bytes,4,opt,name=assigned_version,json=assignedVersion,proto3" json:"assigned_version,omitempty"`
	// contains filtered or unexported fields
}

RegisterRulesetResponse confirms ruleset registration

func (*RegisterRulesetResponse) Descriptor deprecated 

func (*RegisterRulesetResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterRulesetResponse.ProtoReflect.Descriptor instead.

func (*RegisterRulesetResponse) GetAssignedVersion 

func (x *RegisterRulesetResponse) GetAssignedVersion() string

func (*RegisterRulesetResponse) GetMessage 

func (x *RegisterRulesetResponse) GetMessage() string

func (*RegisterRulesetResponse) GetSchemaWarnings 

func (x *RegisterRulesetResponse) GetSchemaWarnings() []string

func (*RegisterRulesetResponse) GetSuccess 

func (x *RegisterRulesetResponse) GetSuccess() bool

func (*RegisterRulesetResponse) ProtoMessage 

func (*RegisterRulesetResponse) ProtoMessage()

func (*RegisterRulesetResponse) ProtoReflect 

func (x *RegisterRulesetResponse) ProtoReflect() protoreflect.Message

func (*RegisterRulesetResponse) Reset 

func (x *RegisterRulesetResponse) Reset()

func (*RegisterRulesetResponse) String 

func (x *RegisterRulesetResponse) String() string

type RegisterVerbInterfaceRequest 

type RegisterVerbInterfaceRequest struct {
	VerbInterface         *VerbInterface `protobuf:"bytes,1,opt,name=verb_interface,json=verbInterface,proto3" json:"verb_interface,omitempty"`
	ValidateCompatibility bool           `protobuf:"varint,2,opt,name=validate_compatibility,json=validateCompatibility,proto3" json:"validate_compatibility,omitempty"`
	ForceUpdate           bool           `protobuf:"varint,3,opt,name=force_update,json=forceUpdate,proto3" json:"force_update,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterVerbInterfaceRequest) Descriptor deprecated 

func (*RegisterVerbInterfaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterVerbInterfaceRequest.ProtoReflect.Descriptor instead.

func (*RegisterVerbInterfaceRequest) GetForceUpdate 

func (x *RegisterVerbInterfaceRequest) GetForceUpdate() bool

func (*RegisterVerbInterfaceRequest) GetValidateCompatibility 

func (x *RegisterVerbInterfaceRequest) GetValidateCompatibility() bool

func (*RegisterVerbInterfaceRequest) GetVerbInterface 

func (x *RegisterVerbInterfaceRequest) GetVerbInterface() *VerbInterface

func (*RegisterVerbInterfaceRequest) ProtoMessage 

func (*RegisterVerbInterfaceRequest) ProtoMessage()

func (*RegisterVerbInterfaceRequest) ProtoReflect 

func (x *RegisterVerbInterfaceRequest) ProtoReflect() protoreflect.Message

func (*RegisterVerbInterfaceRequest) Reset 

func (x *RegisterVerbInterfaceRequest) Reset()

func (*RegisterVerbInterfaceRequest) String 

func (x *RegisterVerbInterfaceRequest) String() string

type RegisterVerbInterfaceResponse 

type RegisterVerbInterfaceResponse struct {
	Success               bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message               string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	AssignedVersion       string   `protobuf:"bytes,3,opt,name=assigned_version,json=assignedVersion,proto3" json:"assigned_version,omitempty"`
	CompatibilityWarnings []string `protobuf:"bytes,4,rep,name=compatibility_warnings,json=compatibilityWarnings,proto3" json:"compatibility_warnings,omitempty"`
	BreakingChanges       []string `protobuf:"bytes,5,rep,name=breaking_changes,json=breakingChanges,proto3" json:"breaking_changes,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterVerbInterfaceResponse) Descriptor deprecated 

func (*RegisterVerbInterfaceResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterVerbInterfaceResponse.ProtoReflect.Descriptor instead.

func (*RegisterVerbInterfaceResponse) GetAssignedVersion 

func (x *RegisterVerbInterfaceResponse) GetAssignedVersion() string

func (*RegisterVerbInterfaceResponse) GetBreakingChanges 

func (x *RegisterVerbInterfaceResponse) GetBreakingChanges() []string

func (*RegisterVerbInterfaceResponse) GetCompatibilityWarnings 

func (x *RegisterVerbInterfaceResponse) GetCompatibilityWarnings() []string

func (*RegisterVerbInterfaceResponse) GetMessage 

func (x *RegisterVerbInterfaceResponse) GetMessage() string

func (*RegisterVerbInterfaceResponse) GetSuccess 

func (x *RegisterVerbInterfaceResponse) GetSuccess() bool

func (*RegisterVerbInterfaceResponse) ProtoMessage 

func (*RegisterVerbInterfaceResponse) ProtoMessage()

func (*RegisterVerbInterfaceResponse) ProtoReflect 

func (x *RegisterVerbInterfaceResponse) ProtoReflect() protoreflect.Message

func (*RegisterVerbInterfaceResponse) Reset 

func (x *RegisterVerbInterfaceResponse) Reset()

func (*RegisterVerbInterfaceResponse) String 

func (x *RegisterVerbInterfaceResponse) String() string

type ResourceLimits 

type ResourceLimits struct {
	MaxMemoryBytes        int64 `protobuf:"varint,1,opt,name=max_memory_bytes,json=maxMemoryBytes,proto3" json:"max_memory_bytes,omitempty"`
	MaxCpuCores           int32 `protobuf:"varint,2,opt,name=max_cpu_cores,json=maxCpuCores,proto3" json:"max_cpu_cores,omitempty"`
	MaxDiskBytes          int64 `protobuf:"varint,3,opt,name=max_disk_bytes,json=maxDiskBytes,proto3" json:"max_disk_bytes,omitempty"`
	MaxNetworkConnections int32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

ResourceLimits define resource consumption limits

func (*ResourceLimits) Descriptor deprecated 

func (*ResourceLimits) Descriptor() ([]byte, []int)

Deprecated: Use ResourceLimits.ProtoReflect.Descriptor instead.

func (*ResourceLimits) GetMaxCpuCores 

func (x *ResourceLimits) GetMaxCpuCores() int32

func (*ResourceLimits) GetMaxDiskBytes 

func (x *ResourceLimits) GetMaxDiskBytes() int64

func (*ResourceLimits) GetMaxMemoryBytes 

func (x *ResourceLimits) GetMaxMemoryBytes() int64

func (*ResourceLimits) GetMaxNetworkConnections 

func (x *ResourceLimits) GetMaxNetworkConnections() int32

func (*ResourceLimits) ProtoMessage 

func (*ResourceLimits) ProtoMessage()

func (*ResourceLimits) ProtoReflect 

func (x *ResourceLimits) ProtoReflect() protoreflect.Message

func (*ResourceLimits) Reset 

func (x *ResourceLimits) Reset()

func (*ResourceLimits) String 

func (x *ResourceLimits) String() string

type ResourceUsage 

type ResourceUsage struct {
	MemoryBytesPeak        int64 `protobuf:"varint,1,opt,name=memory_bytes_peak,json=memoryBytesPeak,proto3" json:"memory_bytes_peak,omitempty"`
	CpuTimeMs              int64 `protobuf:"varint,2,opt,name=cpu_time_ms,json=cpuTimeMs,proto3" json:"cpu_time_ms,omitempty"`
	DiskBytesRead          int64 `protobuf:"varint,3,opt,name=disk_bytes_read,json=diskBytesRead,proto3" json:"disk_bytes_read,omitempty"`
	DiskBytesWritten       int64 `protobuf:"varint,4,opt,name=disk_bytes_written,json=diskBytesWritten,proto3" json:"disk_bytes_written,omitempty"`
	NetworkConnectionsUsed int32 `` /* 130-byte string literal not displayed */
	NetworkBytesSent       int64 `protobuf:"varint,6,opt,name=network_bytes_sent,json=networkBytesSent,proto3" json:"network_bytes_sent,omitempty"`
	NetworkBytesReceived   int64 `protobuf:"varint,7,opt,name=network_bytes_received,json=networkBytesReceived,proto3" json:"network_bytes_received,omitempty"`
	// contains filtered or unexported fields
}

ResourceUsage tracks resource consumption during execution

func (*ResourceUsage) Descriptor deprecated 

func (*ResourceUsage) Descriptor() ([]byte, []int)

Deprecated: Use ResourceUsage.ProtoReflect.Descriptor instead.

func (*ResourceUsage) GetCpuTimeMs 

func (x *ResourceUsage) GetCpuTimeMs() int64

func (*ResourceUsage) GetDiskBytesRead 

func (x *ResourceUsage) GetDiskBytesRead() int64

func (*ResourceUsage) GetDiskBytesWritten 

func (x *ResourceUsage) GetDiskBytesWritten() int64

func (*ResourceUsage) GetMemoryBytesPeak 

func (x *ResourceUsage) GetMemoryBytesPeak() int64

func (*ResourceUsage) GetNetworkBytesReceived 

func (x *ResourceUsage) GetNetworkBytesReceived() int64

func (*ResourceUsage) GetNetworkBytesSent 

func (x *ResourceUsage) GetNetworkBytesSent() int64

func (*ResourceUsage) GetNetworkConnectionsUsed 

func (x *ResourceUsage) GetNetworkConnectionsUsed() int32

func (*ResourceUsage) ProtoMessage 

func (*ResourceUsage) ProtoMessage()

func (*ResourceUsage) ProtoReflect 

func (x *ResourceUsage) ProtoReflect() protoreflect.Message

func (*ResourceUsage) Reset 

func (x *ResourceUsage) Reset()

func (*ResourceUsage) String 

func (x *ResourceUsage) String() string

type RetryPolicy 

type RetryPolicy struct {
	MaxAttempts         int32   `protobuf:"varint,1,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	InitialDelay        string  `protobuf:"bytes,2,opt,name=initial_delay,json=initialDelay,proto3" json:"initial_delay,omitempty"` // Duration string
	MaxDelay            string  `protobuf:"bytes,3,opt,name=max_delay,json=maxDelay,proto3" json:"max_delay,omitempty"`             // Duration string
	BackoffMultiplier   float64 `protobuf:"fixed64,4,opt,name=backoff_multiplier,json=backoffMultiplier,proto3" json:"backoff_multiplier,omitempty"`
	RetryableErrorCodes []int32 `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

RetryPolicy defines how failed verb executions should be retried

func (*RetryPolicy) Descriptor deprecated 

func (*RetryPolicy) Descriptor() ([]byte, []int)

Deprecated: Use RetryPolicy.ProtoReflect.Descriptor instead.

func (*RetryPolicy) GetBackoffMultiplier 

func (x *RetryPolicy) GetBackoffMultiplier() float64

func (*RetryPolicy) GetInitialDelay 

func (x *RetryPolicy) GetInitialDelay() string

func (*RetryPolicy) GetMaxAttempts 

func (x *RetryPolicy) GetMaxAttempts() int32

func (*RetryPolicy) GetMaxDelay 

func (x *RetryPolicy) GetMaxDelay() string

func (*RetryPolicy) GetRetryableErrorCodes 

func (x *RetryPolicy) GetRetryableErrorCodes() []int32

func (*RetryPolicy) ProtoMessage 

func (*RetryPolicy) ProtoMessage()

func (*RetryPolicy) ProtoReflect 

func (x *RetryPolicy) ProtoReflect() protoreflect.Message

func (*RetryPolicy) Reset 

func (x *RetryPolicy) Reset()

func (*RetryPolicy) String 

func (x *RetryPolicy) String() string

type RuleArtifact 

type RuleArtifact struct {
	FormatVersion     uint32            `protobuf:"varint,1,opt,name=format_version,json=formatVersion,proto3" json:"format_version,omitempty"`
	Compiler          *CompilerMetadata `protobuf:"bytes,2,opt,name=compiler,proto3" json:"compiler,omitempty"`
	EnvironmentDigest string            `protobuf:"bytes,3,opt,name=environment_digest,json=environmentDigest,proto3" json:"environment_digest,omitempty"`
	Plans             []*Plan           `protobuf:"bytes,4,rep,name=plans,proto3" json:"plans,omitempty"`
	// contains filtered or unexported fields
}

RuleArtifact is the portable, callback-free execution representation.

func (*RuleArtifact) Descriptor deprecated 

func (*RuleArtifact) Descriptor() ([]byte, []int)

Deprecated: Use RuleArtifact.ProtoReflect.Descriptor instead.

func (*RuleArtifact) GetCompiler 

func (x *RuleArtifact) GetCompiler() *CompilerMetadata

func (*RuleArtifact) GetEnvironmentDigest 

func (x *RuleArtifact) GetEnvironmentDigest() string

func (*RuleArtifact) GetFormatVersion 

func (x *RuleArtifact) GetFormatVersion() uint32

func (*RuleArtifact) GetPlans 

func (x *RuleArtifact) GetPlans() []*Plan

func (*RuleArtifact) ProtoMessage 

func (*RuleArtifact) ProtoMessage()

func (*RuleArtifact) ProtoReflect 

func (x *RuleArtifact) ProtoReflect() protoreflect.Message

func (*RuleArtifact) Reset 

func (x *RuleArtifact) Reset()

func (*RuleArtifact) String 

func (x *RuleArtifact) String() string

type RuleType 

type RuleType int32

RuleType defines the type of rule 

const (
	RuleType_RULE_TYPE_UNSPECIFIED RuleType = 0
	RuleType_RULE_TYPE_LIST        RuleType = 1
	RuleType_RULE_TYPE_FLOW        RuleType = 2
)

func (RuleType) Descriptor 

func (RuleType) Descriptor() protoreflect.EnumDescriptor

func (RuleType) Enum 

func (x RuleType) Enum() *RuleType

func (RuleType) EnumDescriptor deprecated 

func (RuleType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RuleType.Descriptor instead.

func (RuleType) Number 

func (x RuleType) Number() protoreflect.EnumNumber

func (RuleType) String 

func (x RuleType) String() string

func (RuleType) Type 

func (RuleType) Type() protoreflect.EnumType

type RulesetExecutionServiceClient 

type RulesetExecutionServiceClient interface {
	// ExecuteRuleset executes a ruleset with provided facts.
	ExecuteRuleset(ctx context.Context, in *ExecutionRequest, opts ...grpc.CallOption) (*ExecutionResponse, error)
	// Management RPCs are reserved and return Unimplemented in effectusd.
	GetRulesetInfo(ctx context.Context, in *RulesetInfoRequest, opts ...grpc.CallOption) (*RulesetInfo, error)
	ListRulesets(ctx context.Context, in *ListRulesetsRequest, opts ...grpc.CallOption) (*ListRulesetsResponse, error)
	RegisterRuleset(ctx context.Context, in *RegisterRulesetRequest, opts ...grpc.CallOption) (*RegisterRulesetResponse, error)
	UnregisterRuleset(ctx context.Context, in *UnregisterRulesetRequest, opts ...grpc.CallOption) (*UnregisterRulesetResponse, error)
	StreamExecution(ctx context.Context, in *ExecutionRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecutionUpdate], error)
	ValidateSchema(ctx context.Context, in *ValidateSchemaRequest, opts ...grpc.CallOption) (*ValidateSchemaResponse, error)
	GetSchemaVersion(ctx context.Context, in *SchemaVersionRequest, opts ...grpc.CallOption) (*SchemaVersionResponse, error)
}

RulesetExecutionServiceClient is the client API for RulesetExecutionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

RulesetExecutionService provides the core gRPC interface for rule execution

func NewRulesetExecutionServiceClient 

func NewRulesetExecutionServiceClient(cc grpc.ClientConnInterface) RulesetExecutionServiceClient

type RulesetExecutionServiceServer 

type RulesetExecutionServiceServer interface {
	// ExecuteRuleset executes a ruleset with provided facts.
	ExecuteRuleset(context.Context, *ExecutionRequest) (*ExecutionResponse, error)
	// Management RPCs are reserved and return Unimplemented in effectusd.
	GetRulesetInfo(context.Context, *RulesetInfoRequest) (*RulesetInfo, error)
	ListRulesets(context.Context, *ListRulesetsRequest) (*ListRulesetsResponse, error)
	RegisterRuleset(context.Context, *RegisterRulesetRequest) (*RegisterRulesetResponse, error)
	UnregisterRuleset(context.Context, *UnregisterRulesetRequest) (*UnregisterRulesetResponse, error)
	StreamExecution(*ExecutionRequest, grpc.ServerStreamingServer[ExecutionUpdate]) error
	ValidateSchema(context.Context, *ValidateSchemaRequest) (*ValidateSchemaResponse, error)
	GetSchemaVersion(context.Context, *SchemaVersionRequest) (*SchemaVersionResponse, error)
	// contains filtered or unexported methods
}

RulesetExecutionServiceServer is the server API for RulesetExecutionService service. All implementations must embed UnimplementedRulesetExecutionServiceServer for forward compatibility.

RulesetExecutionService provides the core gRPC interface for rule execution

type RulesetExecutionService_StreamExecutionClient 

type RulesetExecutionService_StreamExecutionClient = grpc.ServerStreamingClient[ExecutionUpdate]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RulesetExecutionService_StreamExecutionServer 

type RulesetExecutionService_StreamExecutionServer = grpc.ServerStreamingServer[ExecutionUpdate]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RulesetInfo 

type RulesetInfo struct {
	Name          string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version       string             `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Description   string             `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	RuleCount     int32              `protobuf:"varint,4,opt,name=rule_count,json=ruleCount,proto3" json:"rule_count,omitempty"`
	VerbCount     int32              `protobuf:"varint,5,opt,name=verb_count,json=verbCount,proto3" json:"verb_count,omitempty"`
	Dependencies  []string           `protobuf:"bytes,6,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	Capabilities  []string           `protobuf:"bytes,7,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	FactSchema    *Schema            `protobuf:"bytes,8,opt,name=fact_schema,json=factSchema,proto3" json:"fact_schema,omitempty"`
	EffectSchemas map[string]*Schema `` /* 174-byte string literal not displayed */
	Metadata      map[string]string  `` /* 144-byte string literal not displayed */
	// Buf-managed schema versions
	SchemaVersions *SchemaVersionInfo `protobuf:"bytes,11,opt,name=schema_versions,json=schemaVersions,proto3" json:"schema_versions,omitempty"`
	// contains filtered or unexported fields
}

RulesetInfo provides comprehensive metadata about a ruleset

func (*RulesetInfo) Descriptor deprecated 

func (*RulesetInfo) Descriptor() ([]byte, []int)

Deprecated: Use RulesetInfo.ProtoReflect.Descriptor instead.

func (*RulesetInfo) GetCapabilities 

func (x *RulesetInfo) GetCapabilities() []string

func (*RulesetInfo) GetDependencies 

func (x *RulesetInfo) GetDependencies() []string

func (*RulesetInfo) GetDescription 

func (x *RulesetInfo) GetDescription() string

func (*RulesetInfo) GetEffectSchemas 

func (x *RulesetInfo) GetEffectSchemas() map[string]*Schema

func (*RulesetInfo) GetFactSchema 

func (x *RulesetInfo) GetFactSchema() *Schema

func (*RulesetInfo) GetMetadata 

func (x *RulesetInfo) GetMetadata() map[string]string

func (*RulesetInfo) GetName 

func (x *RulesetInfo) GetName() string

func (*RulesetInfo) GetRuleCount 

func (x *RulesetInfo) GetRuleCount() int32

func (*RulesetInfo) GetSchemaVersions 

func (x *RulesetInfo) GetSchemaVersions() *SchemaVersionInfo

func (*RulesetInfo) GetVerbCount 

func (x *RulesetInfo) GetVerbCount() int32

func (*RulesetInfo) GetVersion 

func (x *RulesetInfo) GetVersion() string

func (*RulesetInfo) ProtoMessage 

func (*RulesetInfo) ProtoMessage()

func (*RulesetInfo) ProtoReflect 

func (x *RulesetInfo) ProtoReflect() protoreflect.Message

func (*RulesetInfo) Reset 

func (x *RulesetInfo) Reset()

func (*RulesetInfo) String 

func (x *RulesetInfo) String() string

type RulesetInfoRequest 

type RulesetInfoRequest struct {
	RulesetName string `protobuf:"bytes,1,opt,name=ruleset_name,json=rulesetName,proto3" json:"ruleset_name,omitempty"`
	Version     string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Optional: specific version
	// contains filtered or unexported fields
}

RulesetInfoRequest requests information about a ruleset

func (*RulesetInfoRequest) Descriptor deprecated 

func (*RulesetInfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use RulesetInfoRequest.ProtoReflect.Descriptor instead.

func (*RulesetInfoRequest) GetRulesetName 

func (x *RulesetInfoRequest) GetRulesetName() string

func (*RulesetInfoRequest) GetVersion 

func (x *RulesetInfoRequest) GetVersion() string

func (*RulesetInfoRequest) ProtoMessage 

func (*RulesetInfoRequest) ProtoMessage()

func (*RulesetInfoRequest) ProtoReflect 

func (x *RulesetInfoRequest) ProtoReflect() protoreflect.Message

func (*RulesetInfoRequest) Reset 

func (x *RulesetInfoRequest) Reset()

func (*RulesetInfoRequest) String 

func (x *RulesetInfoRequest) String() string

type Schema 

type Schema struct {
	Name           string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version        string             `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Package        string             `protobuf:"bytes,3,opt,name=package,proto3" json:"package,omitempty"`
	Fields         []*FieldDescriptor `protobuf:"bytes,4,rep,name=fields,proto3" json:"fields,omitempty"`
	RequiredFields []string           `protobuf:"bytes,5,rep,name=required_fields,json=requiredFields,proto3" json:"required_fields,omitempty"`
	Description    string             `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Validation rules
	ValidationConstraints []*ValidationConstraint `protobuf:"bytes,7,rep,name=validation_constraints,json=validationConstraints,proto3" json:"validation_constraints,omitempty"`
	// Buf registry information
	BufModule string `protobuf:"bytes,8,opt,name=buf_module,json=bufModule,proto3" json:"buf_module,omitempty"`
	BufCommit string `protobuf:"bytes,9,opt,name=buf_commit,json=bufCommit,proto3" json:"buf_commit,omitempty"`
	// JSON Schema equivalent (for non-protobuf systems)
	JsonSchema string `protobuf:"bytes,10,opt,name=json_schema,json=jsonSchema,proto3" json:"json_schema,omitempty"`
	// contains filtered or unexported fields
}

Schema represents a Buf-managed protobuf schema

func (*Schema) Descriptor deprecated 

func (*Schema) Descriptor() ([]byte, []int)

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetBufCommit 

func (x *Schema) GetBufCommit() string

func (*Schema) GetBufModule 

func (x *Schema) GetBufModule() string

func (*Schema) GetDescription 

func (x *Schema) GetDescription() string

func (*Schema) GetFields 

func (x *Schema) GetFields() []*FieldDescriptor

func (*Schema) GetJsonSchema 

func (x *Schema) GetJsonSchema() string

func (*Schema) GetName 

func (x *Schema) GetName() string

func (*Schema) GetPackage 

func (x *Schema) GetPackage() string

func (*Schema) GetRequiredFields 

func (x *Schema) GetRequiredFields() []string

func (*Schema) GetValidationConstraints 

func (x *Schema) GetValidationConstraints() []*ValidationConstraint

func (*Schema) GetVersion 

func (x *Schema) GetVersion() string

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

func (x *Schema) ProtoReflect() protoreflect.Message

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type SchemaCompatibilityStatus 

type SchemaCompatibilityStatus struct {
	Compatible        bool     `protobuf:"varint,1,opt,name=compatible,proto3" json:"compatible,omitempty"`
	Warnings          []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	Errors            []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	RecommendedAction string   `protobuf:"bytes,4,opt,name=recommended_action,json=recommendedAction,proto3" json:"recommended_action,omitempty"`
	// contains filtered or unexported fields
}

SchemaCompatibilityStatus tracks schema compatibility during execution

func (*SchemaCompatibilityStatus) Descriptor deprecated 

func (*SchemaCompatibilityStatus) Descriptor() ([]byte, []int)

Deprecated: Use SchemaCompatibilityStatus.ProtoReflect.Descriptor instead.

func (*SchemaCompatibilityStatus) GetCompatible 

func (x *SchemaCompatibilityStatus) GetCompatible() bool

func (*SchemaCompatibilityStatus) GetErrors 

func (x *SchemaCompatibilityStatus) GetErrors() []string

func (*SchemaCompatibilityStatus) GetRecommendedAction 

func (x *SchemaCompatibilityStatus) GetRecommendedAction() string

func (*SchemaCompatibilityStatus) GetWarnings 

func (x *SchemaCompatibilityStatus) GetWarnings() []string

func (*SchemaCompatibilityStatus) ProtoMessage 

func (*SchemaCompatibilityStatus) ProtoMessage()

func (*SchemaCompatibilityStatus) ProtoReflect 

func (x *SchemaCompatibilityStatus) ProtoReflect() protoreflect.Message

func (*SchemaCompatibilityStatus) Reset 

func (x *SchemaCompatibilityStatus) Reset()

func (*SchemaCompatibilityStatus) String 

func (x *SchemaCompatibilityStatus) String() string

type SchemaInfo 

type SchemaInfo struct {
	FactSchemaVersion    string            `protobuf:"bytes,1,opt,name=fact_schema_version,json=factSchemaVersion,proto3" json:"fact_schema_version,omitempty"`
	EffectSchemaVersions map[string]string `` /* 197-byte string literal not displayed */
	VerbInterfaceVersion string            `protobuf:"bytes,3,opt,name=verb_interface_version,json=verbInterfaceVersion,proto3" json:"verb_interface_version,omitempty"`
	BreakingChanges      []string          `protobuf:"bytes,4,rep,name=breaking_changes,json=breakingChanges,proto3" json:"breaking_changes,omitempty"`
	// contains filtered or unexported fields
}

SchemaInfo provides information about schemas used

func (*SchemaInfo) Descriptor deprecated 

func (*SchemaInfo) Descriptor() ([]byte, []int)

Deprecated: Use SchemaInfo.ProtoReflect.Descriptor instead.

func (*SchemaInfo) GetBreakingChanges 

func (x *SchemaInfo) GetBreakingChanges() []string

func (*SchemaInfo) GetEffectSchemaVersions 

func (x *SchemaInfo) GetEffectSchemaVersions() map[string]string

func (*SchemaInfo) GetFactSchemaVersion 

func (x *SchemaInfo) GetFactSchemaVersion() string

func (*SchemaInfo) GetVerbInterfaceVersion 

func (x *SchemaInfo) GetVerbInterfaceVersion() string

func (*SchemaInfo) ProtoMessage 

func (*SchemaInfo) ProtoMessage()

func (*SchemaInfo) ProtoReflect 

func (x *SchemaInfo) ProtoReflect() protoreflect.Message

func (*SchemaInfo) Reset 

func (x *SchemaInfo) Reset()

func (*SchemaInfo) String 

func (x *SchemaInfo) String() string

type SchemaRegistryInfo 

type SchemaRegistryInfo struct {
	RegistryUrl       string   `protobuf:"bytes,1,opt,name=registry_url,json=registryUrl,proto3" json:"registry_url,omitempty"`
	ModuleName        string   `protobuf:"bytes,2,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	CurrentCommit     string   `protobuf:"bytes,3,opt,name=current_commit,json=currentCommit,proto3" json:"current_commit,omitempty"`
	AvailableVersions []string `protobuf:"bytes,4,rep,name=available_versions,json=availableVersions,proto3" json:"available_versions,omitempty"`
	// contains filtered or unexported fields
}

SchemaRegistryInfo provides information about the Buf schema registry

func (*SchemaRegistryInfo) Descriptor deprecated 

func (*SchemaRegistryInfo) Descriptor() ([]byte, []int)

Deprecated: Use SchemaRegistryInfo.ProtoReflect.Descriptor instead.

func (*SchemaRegistryInfo) GetAvailableVersions 

func (x *SchemaRegistryInfo) GetAvailableVersions() []string

func (*SchemaRegistryInfo) GetCurrentCommit 

func (x *SchemaRegistryInfo) GetCurrentCommit() string

func (*SchemaRegistryInfo) GetModuleName 

func (x *SchemaRegistryInfo) GetModuleName() string

func (*SchemaRegistryInfo) GetRegistryUrl 

func (x *SchemaRegistryInfo) GetRegistryUrl() string

func (*SchemaRegistryInfo) ProtoMessage 

func (*SchemaRegistryInfo) ProtoMessage()

func (*SchemaRegistryInfo) ProtoReflect 

func (x *SchemaRegistryInfo) ProtoReflect() protoreflect.Message

func (*SchemaRegistryInfo) Reset 

func (x *SchemaRegistryInfo) Reset()

func (*SchemaRegistryInfo) String 

func (x *SchemaRegistryInfo) String() string

type SchemaValidation 

type SchemaValidation struct {
	StrictMode             bool     `protobuf:"varint,1,opt,name=strict_mode,json=strictMode,proto3" json:"strict_mode,omitempty"`
	AllowUnknownFields     bool     `protobuf:"varint,2,opt,name=allow_unknown_fields,json=allowUnknownFields,proto3" json:"allow_unknown_fields,omitempty"`
	ValidateRequiredFields bool     `` /* 130-byte string literal not displayed */
	IgnoredFields          []string `protobuf:"bytes,4,rep,name=ignored_fields,json=ignoredFields,proto3" json:"ignored_fields,omitempty"`
	// contains filtered or unexported fields
}

SchemaValidation is unsupported by effectusd and preserved for wire compatibility.

func (*SchemaValidation) Descriptor deprecated 

func (*SchemaValidation) Descriptor() ([]byte, []int)

Deprecated: Use SchemaValidation.ProtoReflect.Descriptor instead.

func (*SchemaValidation) GetAllowUnknownFields 

func (x *SchemaValidation) GetAllowUnknownFields() bool

func (*SchemaValidation) GetIgnoredFields 

func (x *SchemaValidation) GetIgnoredFields() []string

func (*SchemaValidation) GetStrictMode 

func (x *SchemaValidation) GetStrictMode() bool

func (*SchemaValidation) GetValidateRequiredFields 

func (x *SchemaValidation) GetValidateRequiredFields() bool

func (*SchemaValidation) ProtoMessage 

func (*SchemaValidation) ProtoMessage()

func (*SchemaValidation) ProtoReflect 

func (x *SchemaValidation) ProtoReflect() protoreflect.Message

func (*SchemaValidation) Reset 

func (x *SchemaValidation) Reset()

func (*SchemaValidation) String 

func (x *SchemaValidation) String() string

type SchemaVersionInfo 

type SchemaVersionInfo struct {
	FactSchemaVersion    string            `protobuf:"bytes,1,opt,name=fact_schema_version,json=factSchemaVersion,proto3" json:"fact_schema_version,omitempty"`
	VerbInterfaceVersion string            `protobuf:"bytes,2,opt,name=verb_interface_version,json=verbInterfaceVersion,proto3" json:"verb_interface_version,omitempty"`
	EffectSchemaVersions map[string]string `` /* 197-byte string literal not displayed */
	RulesetSchemaVersion string            `protobuf:"bytes,4,opt,name=ruleset_schema_version,json=rulesetSchemaVersion,proto3" json:"ruleset_schema_version,omitempty"`
	// Compatibility information
	CompatibleVersions   []string `protobuf:"bytes,5,rep,name=compatible_versions,json=compatibleVersions,proto3" json:"compatible_versions,omitempty"`
	BreakingChangesSince []string `protobuf:"bytes,6,rep,name=breaking_changes_since,json=breakingChangesSince,proto3" json:"breaking_changes_since,omitempty"`
	// contains filtered or unexported fields
}

SchemaVersionInfo tracks Buf-managed schema versions

func (*SchemaVersionInfo) Descriptor deprecated 

func (*SchemaVersionInfo) Descriptor() ([]byte, []int)

Deprecated: Use SchemaVersionInfo.ProtoReflect.Descriptor instead.

func (*SchemaVersionInfo) GetBreakingChangesSince 

func (x *SchemaVersionInfo) GetBreakingChangesSince() []string

func (*SchemaVersionInfo) GetCompatibleVersions 

func (x *SchemaVersionInfo) GetCompatibleVersions() []string

func (*SchemaVersionInfo) GetEffectSchemaVersions 

func (x *SchemaVersionInfo) GetEffectSchemaVersions() map[string]string

func (*SchemaVersionInfo) GetFactSchemaVersion 

func (x *SchemaVersionInfo) GetFactSchemaVersion() string

func (*SchemaVersionInfo) GetRulesetSchemaVersion 

func (x *SchemaVersionInfo) GetRulesetSchemaVersion() string

func (*SchemaVersionInfo) GetVerbInterfaceVersion 

func (x *SchemaVersionInfo) GetVerbInterfaceVersion() string

func (*SchemaVersionInfo) ProtoMessage 

func (*SchemaVersionInfo) ProtoMessage()

func (*SchemaVersionInfo) ProtoReflect 

func (x *SchemaVersionInfo) ProtoReflect() protoreflect.Message

func (*SchemaVersionInfo) Reset 

func (x *SchemaVersionInfo) Reset()

func (*SchemaVersionInfo) String 

func (x *SchemaVersionInfo) String() string

type SchemaVersionRequest 

type SchemaVersionRequest struct {
	SchemaName string `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	ModuleName string `protobuf:"bytes,2,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	// contains filtered or unexported fields
}

SchemaVersionRequest requests schema version information

func (*SchemaVersionRequest) Descriptor deprecated 

func (*SchemaVersionRequest) Descriptor() ([]byte, []int)

Deprecated: Use SchemaVersionRequest.ProtoReflect.Descriptor instead.

func (*SchemaVersionRequest) GetModuleName 

func (x *SchemaVersionRequest) GetModuleName() string

func (*SchemaVersionRequest) GetSchemaName 

func (x *SchemaVersionRequest) GetSchemaName() string

func (*SchemaVersionRequest) ProtoMessage 

func (*SchemaVersionRequest) ProtoMessage()

func (*SchemaVersionRequest) ProtoReflect 

func (x *SchemaVersionRequest) ProtoReflect() protoreflect.Message

func (*SchemaVersionRequest) Reset 

func (x *SchemaVersionRequest) Reset()

func (*SchemaVersionRequest) String 

func (x *SchemaVersionRequest) String() string

type SchemaVersionResponse 

type SchemaVersionResponse struct {
	CurrentVersion      string            `protobuf:"bytes,1,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"`
	AvailableVersions   []string          `protobuf:"bytes,2,rep,name=available_versions,json=availableVersions,proto3" json:"available_versions,omitempty"`
	LatestStableVersion string            `protobuf:"bytes,3,opt,name=latest_stable_version,json=latestStableVersion,proto3" json:"latest_stable_version,omitempty"`
	VersionMetadata     map[string]string `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

SchemaVersionResponse returns schema version information

func (*SchemaVersionResponse) Descriptor deprecated 

func (*SchemaVersionResponse) Descriptor() ([]byte, []int)

Deprecated: Use SchemaVersionResponse.ProtoReflect.Descriptor instead.

func (*SchemaVersionResponse) GetAvailableVersions 

func (x *SchemaVersionResponse) GetAvailableVersions() []string

func (*SchemaVersionResponse) GetCurrentVersion 

func (x *SchemaVersionResponse) GetCurrentVersion() string

func (*SchemaVersionResponse) GetLatestStableVersion 

func (x *SchemaVersionResponse) GetLatestStableVersion() string

func (*SchemaVersionResponse) GetVersionMetadata 

func (x *SchemaVersionResponse) GetVersionMetadata() map[string]string

func (*SchemaVersionResponse) ProtoMessage 

func (*SchemaVersionResponse) ProtoMessage()

func (*SchemaVersionResponse) ProtoReflect 

func (x *SchemaVersionResponse) ProtoReflect() protoreflect.Message

func (*SchemaVersionResponse) Reset 

func (x *SchemaVersionResponse) Reset()

func (*SchemaVersionResponse) String 

func (x *SchemaVersionResponse) String() string

type SecurityConstraints 

type SecurityConstraints struct {

	// Authentication requirements
	RequiredAuthMethods []string `protobuf:"bytes,1,rep,name=required_auth_methods,json=requiredAuthMethods,proto3" json:"required_auth_methods,omitempty"`
	// Authorization requirements
	RequiredPermissions []string `protobuf:"bytes,2,rep,name=required_permissions,json=requiredPermissions,proto3" json:"required_permissions,omitempty"`
	// Audit requirements
	AuditAllCalls     bool `protobuf:"varint,3,opt,name=audit_all_calls,json=auditAllCalls,proto3" json:"audit_all_calls,omitempty"`
	AuditFailuresOnly bool `protobuf:"varint,4,opt,name=audit_failures_only,json=auditFailuresOnly,proto3" json:"audit_failures_only,omitempty"`
	// Data sensitivity level
	DataSensitivity DataSensitivityLevel `` /* 145-byte string literal not displayed */
	// Encryption requirements
	RequireEncryption bool `protobuf:"varint,6,opt,name=require_encryption,json=requireEncryption,proto3" json:"require_encryption,omitempty"`
	// contains filtered or unexported fields
}

SecurityConstraints define security requirements

func (*SecurityConstraints) Descriptor deprecated 

func (*SecurityConstraints) Descriptor() ([]byte, []int)

Deprecated: Use SecurityConstraints.ProtoReflect.Descriptor instead.

func (*SecurityConstraints) GetAuditAllCalls 

func (x *SecurityConstraints) GetAuditAllCalls() bool

func (*SecurityConstraints) GetAuditFailuresOnly 

func (x *SecurityConstraints) GetAuditFailuresOnly() bool

func (*SecurityConstraints) GetDataSensitivity 

func (x *SecurityConstraints) GetDataSensitivity() DataSensitivityLevel

func (*SecurityConstraints) GetRequireEncryption 

func (x *SecurityConstraints) GetRequireEncryption() bool

func (*SecurityConstraints) GetRequiredAuthMethods 

func (x *SecurityConstraints) GetRequiredAuthMethods() []string

func (*SecurityConstraints) GetRequiredPermissions 

func (x *SecurityConstraints) GetRequiredPermissions() []string

func (*SecurityConstraints) ProtoMessage 

func (*SecurityConstraints) ProtoMessage()

func (*SecurityConstraints) ProtoReflect 

func (x *SecurityConstraints) ProtoReflect() protoreflect.Message

func (*SecurityConstraints) Reset 

func (x *SecurityConstraints) Reset()

func (*SecurityConstraints) String 

func (x *SecurityConstraints) String() string

type SecurityContext 

type SecurityContext struct {
	PrincipalId          string                 `protobuf:"bytes,1,opt,name=principal_id,json=principalId,proto3" json:"principal_id,omitempty"`
	Roles                []string               `protobuf:"bytes,2,rep,name=roles,proto3" json:"roles,omitempty"`
	Permissions          []string               `protobuf:"bytes,3,rep,name=permissions,proto3" json:"permissions,omitempty"`
	AuthenticationMethod string                 `protobuf:"bytes,4,opt,name=authentication_method,json=authenticationMethod,proto3" json:"authentication_method,omitempty"`
	AuthenticatedAt      *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=authenticated_at,json=authenticatedAt,proto3" json:"authenticated_at,omitempty"`
	// contains filtered or unexported fields
}

SecurityContext provides security information

func (*SecurityContext) Descriptor deprecated 

func (*SecurityContext) Descriptor() ([]byte, []int)

Deprecated: Use SecurityContext.ProtoReflect.Descriptor instead.

func (*SecurityContext) GetAuthenticatedAt 

func (x *SecurityContext) GetAuthenticatedAt() *timestamppb.Timestamp

func (*SecurityContext) GetAuthenticationMethod 

func (x *SecurityContext) GetAuthenticationMethod() string

func (*SecurityContext) GetPermissions 

func (x *SecurityContext) GetPermissions() []string

func (*SecurityContext) GetPrincipalId 

func (x *SecurityContext) GetPrincipalId() string

func (*SecurityContext) GetRoles 

func (x *SecurityContext) GetRoles() []string

func (*SecurityContext) ProtoMessage 

func (*SecurityContext) ProtoMessage()

func (*SecurityContext) ProtoReflect 

func (x *SecurityContext) ProtoReflect() protoreflect.Message

func (*SecurityContext) Reset 

func (x *SecurityContext) Reset()

func (*SecurityContext) String 

func (x *SecurityContext) String() string

type SourceDialect 

type SourceDialect int32
const (
	SourceDialect_SOURCE_DIALECT_UNSPECIFIED SourceDialect = 0
	SourceDialect_SOURCE_DIALECT_LIST        SourceDialect = 1
	SourceDialect_SOURCE_DIALECT_FLOW        SourceDialect = 2
)

func (SourceDialect) Descriptor 

func (SourceDialect) Descriptor() protoreflect.EnumDescriptor

func (SourceDialect) Enum 

func (x SourceDialect) Enum() *SourceDialect

func (SourceDialect) EnumDescriptor deprecated 

func (SourceDialect) EnumDescriptor() ([]byte, []int)

Deprecated: Use SourceDialect.Descriptor instead.

func (SourceDialect) Number 

func (x SourceDialect) Number() protoreflect.EnumNumber

func (SourceDialect) String 

func (x SourceDialect) String() string

func (SourceDialect) Type 

func (SourceDialect) Type() protoreflect.EnumType

type Step 

type Step struct {
	Id                 string                `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Ordinal            uint32                `protobuf:"varint,2,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	Verb               string                `protobuf:"bytes,3,opt,name=verb,proto3" json:"verb,omitempty"`
	ContractHash       string                `protobuf:"bytes,4,opt,name=contract_hash,json=contractHash,proto3" json:"contract_hash,omitempty"`
	Arguments          []*Argument           `protobuf:"bytes,5,rep,name=arguments,proto3" json:"arguments,omitempty"`
	ResultSlot         *uint32               `protobuf:"varint,6,opt,name=result_slot,json=resultSlot,proto3,oneof" json:"result_slot,omitempty"`
	Compensation       *CompensationContract `protobuf:"bytes,7,opt,name=compensation,proto3" json:"compensation,omitempty"`
	RetryPolicy        *CheckedRetryPolicy   `protobuf:"bytes,8,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	IdempotencyPolicy  IdempotencyPolicy     `` /* 148-byte string literal not displayed */
	FencingRequirement FencingRequirement    `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Step) Descriptor deprecated 

func (*Step) Descriptor() ([]byte, []int)

Deprecated: Use Step.ProtoReflect.Descriptor instead.

func (*Step) GetArguments 

func (x *Step) GetArguments() []*Argument

func (*Step) GetCompensation 

func (x *Step) GetCompensation() *CompensationContract

func (*Step) GetContractHash 

func (x *Step) GetContractHash() string

func (*Step) GetFencingRequirement 

func (x *Step) GetFencingRequirement() FencingRequirement

func (*Step) GetId 

func (x *Step) GetId() string

func (*Step) GetIdempotencyPolicy 

func (x *Step) GetIdempotencyPolicy() IdempotencyPolicy

func (*Step) GetOrdinal 

func (x *Step) GetOrdinal() uint32

func (*Step) GetResultSlot 

func (x *Step) GetResultSlot() uint32

func (*Step) GetRetryPolicy 

func (x *Step) GetRetryPolicy() *CheckedRetryPolicy

func (*Step) GetVerb 

func (x *Step) GetVerb() string

func (*Step) ProtoMessage 

func (*Step) ProtoMessage()

func (*Step) ProtoReflect 

func (x *Step) ProtoReflect() protoreflect.Message

func (*Step) Reset 

func (x *Step) Reset()

func (*Step) String 

func (x *Step) String() string

type TypedEffect 

type TypedEffect struct {
	VerbName  string                 `protobuf:"bytes,1,opt,name=verb_name,json=verbName,proto3" json:"verb_name,omitempty"`
	Args      *anypb.Any             `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	Result    *anypb.Any             `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Status    EffectStatus           `protobuf:"varint,5,opt,name=status,proto3,enum=effectus.v1.EffectStatus" json:"status,omitempty"`
	// Schema version used for this effect
	SchemaVersion string `protobuf:"bytes,6,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// Capability required for this effect
	Capability string `protobuf:"bytes,7,opt,name=capability,proto3" json:"capability,omitempty"`
	// contains filtered or unexported fields
}

TypedEffect represents an effect with full type information

func (*TypedEffect) Descriptor deprecated 

func (*TypedEffect) Descriptor() ([]byte, []int)

Deprecated: Use TypedEffect.ProtoReflect.Descriptor instead.

func (*TypedEffect) GetArgs 

func (x *TypedEffect) GetArgs() *anypb.Any

func (*TypedEffect) GetCapability 

func (x *TypedEffect) GetCapability() string

func (*TypedEffect) GetResult 

func (x *TypedEffect) GetResult() *anypb.Any

func (*TypedEffect) GetSchemaVersion 

func (x *TypedEffect) GetSchemaVersion() string

func (*TypedEffect) GetStatus 

func (x *TypedEffect) GetStatus() EffectStatus

func (*TypedEffect) GetTimestamp 

func (x *TypedEffect) GetTimestamp() *timestamppb.Timestamp

func (*TypedEffect) GetVerbName 

func (x *TypedEffect) GetVerbName() string

func (*TypedEffect) ProtoMessage 

func (*TypedEffect) ProtoMessage()

func (*TypedEffect) ProtoReflect 

func (x *TypedEffect) ProtoReflect() protoreflect.Message

func (*TypedEffect) Reset 

func (x *TypedEffect) Reset()

func (*TypedEffect) String 

func (x *TypedEffect) String() string

type UnaryExpression 

type UnaryExpression struct {
	Operator UnaryOperator `protobuf:"varint,1,opt,name=operator,proto3,enum=effectus.v1.UnaryOperator" json:"operator,omitempty"`
	Operand  *Expression   `protobuf:"bytes,2,opt,name=operand,proto3" json:"operand,omitempty"`
	// contains filtered or unexported fields
}

func (*UnaryExpression) Descriptor deprecated 

func (*UnaryExpression) Descriptor() ([]byte, []int)

Deprecated: Use UnaryExpression.ProtoReflect.Descriptor instead.

func (*UnaryExpression) GetOperand 

func (x *UnaryExpression) GetOperand() *Expression

func (*UnaryExpression) GetOperator 

func (x *UnaryExpression) GetOperator() UnaryOperator

func (*UnaryExpression) ProtoMessage 

func (*UnaryExpression) ProtoMessage()

func (*UnaryExpression) ProtoReflect 

func (x *UnaryExpression) ProtoReflect() protoreflect.Message

func (*UnaryExpression) Reset 

func (x *UnaryExpression) Reset()

func (*UnaryExpression) String 

func (x *UnaryExpression) String() string

type UnaryOperator 

type UnaryOperator int32
const (
	UnaryOperator_UNARY_OPERATOR_UNSPECIFIED UnaryOperator = 0
	UnaryOperator_UNARY_OPERATOR_NOT         UnaryOperator = 1
	UnaryOperator_UNARY_OPERATOR_NEGATE      UnaryOperator = 2
)

func (UnaryOperator) Descriptor 

func (UnaryOperator) Descriptor() protoreflect.EnumDescriptor

func (UnaryOperator) Enum 

func (x UnaryOperator) Enum() *UnaryOperator

func (UnaryOperator) EnumDescriptor deprecated 

func (UnaryOperator) EnumDescriptor() ([]byte, []int)

Deprecated: Use UnaryOperator.Descriptor instead.

func (UnaryOperator) Number 

func (x UnaryOperator) Number() protoreflect.EnumNumber

func (UnaryOperator) String 

func (x UnaryOperator) String() string

func (UnaryOperator) Type 

func (UnaryOperator) Type() protoreflect.EnumType

type UnimplementedFactRegistryServiceServer 

type UnimplementedFactRegistryServiceServer struct{}

UnimplementedFactRegistryServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedFactRegistryServiceServer) CheckCompatibility 

func (UnimplementedFactRegistryServiceServer) CheckCompatibility(context.Context, *CheckCompatibilityRequest) (*CheckCompatibilityResponse, error)

func (UnimplementedFactRegistryServiceServer) GetFactSchema 

func (UnimplementedFactRegistryServiceServer) GetFactSchema(context.Context, *GetFactSchemaRequest) (*GetFactSchemaResponse, error)

func (UnimplementedFactRegistryServiceServer) ListFactSchemas 

func (UnimplementedFactRegistryServiceServer) ListFactSchemas(context.Context, *ListFactSchemasRequest) (*ListFactSchemasResponse, error)

func (UnimplementedFactRegistryServiceServer) RegisterFactSchema 

func (UnimplementedFactRegistryServiceServer) RegisterFactSchema(context.Context, *RegisterFactSchemaRequest) (*RegisterFactSchemaResponse, error)

func (UnimplementedFactRegistryServiceServer) ValidateFactData 

func (UnimplementedFactRegistryServiceServer) ValidateFactData(context.Context, *ValidateFactDataRequest) (*ValidateFactDataResponse, error)

type UnimplementedRulesetExecutionServiceServer 

type UnimplementedRulesetExecutionServiceServer struct{}

UnimplementedRulesetExecutionServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedRulesetExecutionServiceServer) ExecuteRuleset 

func (UnimplementedRulesetExecutionServiceServer) ExecuteRuleset(context.Context, *ExecutionRequest) (*ExecutionResponse, error)

func (UnimplementedRulesetExecutionServiceServer) GetRulesetInfo 

func (UnimplementedRulesetExecutionServiceServer) GetRulesetInfo(context.Context, *RulesetInfoRequest) (*RulesetInfo, error)

func (UnimplementedRulesetExecutionServiceServer) GetSchemaVersion 

func (UnimplementedRulesetExecutionServiceServer) GetSchemaVersion(context.Context, *SchemaVersionRequest) (*SchemaVersionResponse, error)

func (UnimplementedRulesetExecutionServiceServer) ListRulesets 

func (UnimplementedRulesetExecutionServiceServer) ListRulesets(context.Context, *ListRulesetsRequest) (*ListRulesetsResponse, error)

func (UnimplementedRulesetExecutionServiceServer) RegisterRuleset 

func (UnimplementedRulesetExecutionServiceServer) RegisterRuleset(context.Context, *RegisterRulesetRequest) (*RegisterRulesetResponse, error)

func (UnimplementedRulesetExecutionServiceServer) StreamExecution 

func (UnimplementedRulesetExecutionServiceServer) StreamExecution(*ExecutionRequest, grpc.ServerStreamingServer[ExecutionUpdate]) error

func (UnimplementedRulesetExecutionServiceServer) UnregisterRuleset 

func (UnimplementedRulesetExecutionServiceServer) UnregisterRuleset(context.Context, *UnregisterRulesetRequest) (*UnregisterRulesetResponse, error)

func (UnimplementedRulesetExecutionServiceServer) ValidateSchema 

func (UnimplementedRulesetExecutionServiceServer) ValidateSchema(context.Context, *ValidateSchemaRequest) (*ValidateSchemaResponse, error)

type UnimplementedVerbRegistryServiceServer 

type UnimplementedVerbRegistryServiceServer struct{}

UnimplementedVerbRegistryServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedVerbRegistryServiceServer) CheckInterfaceCompatibility 

func (UnimplementedVerbRegistryServiceServer) CheckInterfaceCompatibility(context.Context, *CheckInterfaceCompatibilityRequest) (*CheckInterfaceCompatibilityResponse, error)

func (UnimplementedVerbRegistryServiceServer) GenerateVerbCode 

func (UnimplementedVerbRegistryServiceServer) GenerateVerbCode(context.Context, *GenerateVerbCodeRequest) (*GenerateVerbCodeResponse, error)

func (UnimplementedVerbRegistryServiceServer) GetVerbInterface 

func (UnimplementedVerbRegistryServiceServer) GetVerbInterface(context.Context, *GetVerbInterfaceRequest) (*GetVerbInterfaceResponse, error)

func (UnimplementedVerbRegistryServiceServer) ListVerbInterfaces 

func (UnimplementedVerbRegistryServiceServer) ListVerbInterfaces(context.Context, *ListVerbInterfacesRequest) (*ListVerbInterfacesResponse, error)

func (UnimplementedVerbRegistryServiceServer) RegisterVerbInterface 

func (UnimplementedVerbRegistryServiceServer) RegisterVerbInterface(context.Context, *RegisterVerbInterfaceRequest) (*RegisterVerbInterfaceResponse, error)

func (UnimplementedVerbRegistryServiceServer) ValidateVerbCall 

func (UnimplementedVerbRegistryServiceServer) ValidateVerbCall(context.Context, *ValidateVerbCallRequest) (*ValidateVerbCallResponse, error)

type UnregisterRulesetRequest 

type UnregisterRulesetRequest struct {
	RulesetName string `protobuf:"bytes,1,opt,name=ruleset_name,json=rulesetName,proto3" json:"ruleset_name,omitempty"`
	Version     string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Force       bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"` // Force removal even if dependencies exist
	// contains filtered or unexported fields
}

UnregisterRulesetRequest removes a ruleset

func (*UnregisterRulesetRequest) Descriptor deprecated 

func (*UnregisterRulesetRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnregisterRulesetRequest.ProtoReflect.Descriptor instead.

func (*UnregisterRulesetRequest) GetForce 

func (x *UnregisterRulesetRequest) GetForce() bool

func (*UnregisterRulesetRequest) GetRulesetName 

func (x *UnregisterRulesetRequest) GetRulesetName() string

func (*UnregisterRulesetRequest) GetVersion 

func (x *UnregisterRulesetRequest) GetVersion() string

func (*UnregisterRulesetRequest) ProtoMessage 

func (*UnregisterRulesetRequest) ProtoMessage()

func (*UnregisterRulesetRequest) ProtoReflect 

func (x *UnregisterRulesetRequest) ProtoReflect() protoreflect.Message

func (*UnregisterRulesetRequest) Reset 

func (x *UnregisterRulesetRequest) Reset()

func (*UnregisterRulesetRequest) String 

func (x *UnregisterRulesetRequest) String() string

type UnregisterRulesetResponse 

type UnregisterRulesetResponse struct {
	Success          bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message          string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	AffectedRulesets []string `protobuf:"bytes,3,rep,name=affected_rulesets,json=affectedRulesets,proto3" json:"affected_rulesets,omitempty"`
	// contains filtered or unexported fields
}

UnregisterRulesetResponse confirms ruleset removal

func (*UnregisterRulesetResponse) Descriptor deprecated 

func (*UnregisterRulesetResponse) Descriptor() ([]byte, []int)

Deprecated: Use UnregisterRulesetResponse.ProtoReflect.Descriptor instead.

func (*UnregisterRulesetResponse) GetAffectedRulesets 

func (x *UnregisterRulesetResponse) GetAffectedRulesets() []string

func (*UnregisterRulesetResponse) GetMessage 

func (x *UnregisterRulesetResponse) GetMessage() string

func (*UnregisterRulesetResponse) GetSuccess 

func (x *UnregisterRulesetResponse) GetSuccess() bool

func (*UnregisterRulesetResponse) ProtoMessage 

func (*UnregisterRulesetResponse) ProtoMessage()

func (*UnregisterRulesetResponse) ProtoReflect 

func (x *UnregisterRulesetResponse) ProtoReflect() protoreflect.Message

func (*UnregisterRulesetResponse) Reset 

func (x *UnregisterRulesetResponse) Reset()

func (*UnregisterRulesetResponse) String 

func (x *UnregisterRulesetResponse) String() string

type UnsafeFactRegistryServiceServer 

type UnsafeFactRegistryServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeFactRegistryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FactRegistryServiceServer will result in compilation errors.

type UnsafeRulesetExecutionServiceServer 

type UnsafeRulesetExecutionServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRulesetExecutionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RulesetExecutionServiceServer will result in compilation errors.

type UnsafeVerbRegistryServiceServer 

type UnsafeVerbRegistryServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeVerbRegistryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VerbRegistryServiceServer will result in compilation errors.

type ValidateFactDataRequest 

type ValidateFactDataRequest struct {
	SchemaName    string     `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	SchemaVersion string     `protobuf:"bytes,2,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	FactData      *anypb.Any `protobuf:"bytes,3,opt,name=fact_data,json=factData,proto3" json:"fact_data,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateFactDataRequest) Descriptor deprecated 

func (*ValidateFactDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateFactDataRequest.ProtoReflect.Descriptor instead.

func (*ValidateFactDataRequest) GetFactData 

func (x *ValidateFactDataRequest) GetFactData() *anypb.Any

func (*ValidateFactDataRequest) GetSchemaName 

func (x *ValidateFactDataRequest) GetSchemaName() string

func (*ValidateFactDataRequest) GetSchemaVersion 

func (x *ValidateFactDataRequest) GetSchemaVersion() string

func (*ValidateFactDataRequest) ProtoMessage 

func (*ValidateFactDataRequest) ProtoMessage()

func (*ValidateFactDataRequest) ProtoReflect 

func (x *ValidateFactDataRequest) ProtoReflect() protoreflect.Message

func (*ValidateFactDataRequest) Reset 

func (x *ValidateFactDataRequest) Reset()

func (*ValidateFactDataRequest) String 

func (x *ValidateFactDataRequest) String() string

type ValidateFactDataResponse 

type ValidateFactDataResponse struct {
	Valid    bool     `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	Errors   []string `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	Warnings []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateFactDataResponse) Descriptor deprecated 

func (*ValidateFactDataResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValidateFactDataResponse.ProtoReflect.Descriptor instead.

func (*ValidateFactDataResponse) GetErrors 

func (x *ValidateFactDataResponse) GetErrors() []string

func (*ValidateFactDataResponse) GetValid 

func (x *ValidateFactDataResponse) GetValid() bool

func (*ValidateFactDataResponse) GetWarnings 

func (x *ValidateFactDataResponse) GetWarnings() []string

func (*ValidateFactDataResponse) ProtoMessage 

func (*ValidateFactDataResponse) ProtoMessage()

func (*ValidateFactDataResponse) ProtoReflect 

func (x *ValidateFactDataResponse) ProtoReflect() protoreflect.Message

func (*ValidateFactDataResponse) Reset 

func (x *ValidateFactDataResponse) Reset()

func (*ValidateFactDataResponse) String 

func (x *ValidateFactDataResponse) String() string

type ValidateSchemaRequest 

type ValidateSchemaRequest struct {
	SchemaName           string     `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	SchemaVersion        string     `protobuf:"bytes,2,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	SchemaDefinition     *anypb.Any `protobuf:"bytes,3,opt,name=schema_definition,json=schemaDefinition,proto3" json:"schema_definition,omitempty"`
	CheckBreakingChanges bool       `protobuf:"varint,4,opt,name=check_breaking_changes,json=checkBreakingChanges,proto3" json:"check_breaking_changes,omitempty"`
	// contains filtered or unexported fields
}

ValidateSchemaRequest validates schemas against the registry

func (*ValidateSchemaRequest) Descriptor deprecated 

func (*ValidateSchemaRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateSchemaRequest.ProtoReflect.Descriptor instead.

func (*ValidateSchemaRequest) GetCheckBreakingChanges 

func (x *ValidateSchemaRequest) GetCheckBreakingChanges() bool

func (*ValidateSchemaRequest) GetSchemaDefinition 

func (x *ValidateSchemaRequest) GetSchemaDefinition() *anypb.Any

func (*ValidateSchemaRequest) GetSchemaName 

func (x *ValidateSchemaRequest) GetSchemaName() string

func (*ValidateSchemaRequest) GetSchemaVersion 

func (x *ValidateSchemaRequest) GetSchemaVersion() string

func (*ValidateSchemaRequest) ProtoMessage 

func (*ValidateSchemaRequest) ProtoMessage()

func (*ValidateSchemaRequest) ProtoReflect 

func (x *ValidateSchemaRequest) ProtoReflect() protoreflect.Message

func (*ValidateSchemaRequest) Reset 

func (x *ValidateSchemaRequest) Reset()

func (*ValidateSchemaRequest) String 

func (x *ValidateSchemaRequest) String() string

type ValidateSchemaResponse 

type ValidateSchemaResponse struct {
	Valid              bool     `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	Errors             []string `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	Warnings           []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	BreakingChanges    []string `protobuf:"bytes,4,rep,name=breaking_changes,json=breakingChanges,proto3" json:"breaking_changes,omitempty"`
	RecommendedVersion string   `protobuf:"bytes,5,opt,name=recommended_version,json=recommendedVersion,proto3" json:"recommended_version,omitempty"`
	// contains filtered or unexported fields
}

ValidateSchemaResponse returns schema validation results

func (*ValidateSchemaResponse) Descriptor deprecated 

func (*ValidateSchemaResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValidateSchemaResponse.ProtoReflect.Descriptor instead.

func (*ValidateSchemaResponse) GetBreakingChanges 

func (x *ValidateSchemaResponse) GetBreakingChanges() []string

func (*ValidateSchemaResponse) GetErrors 

func (x *ValidateSchemaResponse) GetErrors() []string

func (*ValidateSchemaResponse) GetRecommendedVersion 

func (x *ValidateSchemaResponse) GetRecommendedVersion() string

func (*ValidateSchemaResponse) GetValid 

func (x *ValidateSchemaResponse) GetValid() bool

func (*ValidateSchemaResponse) GetWarnings 

func (x *ValidateSchemaResponse) GetWarnings() []string

func (*ValidateSchemaResponse) ProtoMessage 

func (*ValidateSchemaResponse) ProtoMessage()

func (*ValidateSchemaResponse) ProtoReflect 

func (x *ValidateSchemaResponse) ProtoReflect() protoreflect.Message

func (*ValidateSchemaResponse) Reset 

func (x *ValidateSchemaResponse) Reset()

func (*ValidateSchemaResponse) String 

func (x *ValidateSchemaResponse) String() string

type ValidateVerbCallRequest 

type ValidateVerbCallRequest struct {
	VerbName         string     `protobuf:"bytes,1,opt,name=verb_name,json=verbName,proto3" json:"verb_name,omitempty"`
	InterfaceVersion string     `protobuf:"bytes,2,opt,name=interface_version,json=interfaceVersion,proto3" json:"interface_version,omitempty"`
	InputData        *anypb.Any `protobuf:"bytes,3,opt,name=input_data,json=inputData,proto3" json:"input_data,omitempty"`
	StrictValidation bool       `protobuf:"varint,4,opt,name=strict_validation,json=strictValidation,proto3" json:"strict_validation,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateVerbCallRequest) Descriptor deprecated 

func (*ValidateVerbCallRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateVerbCallRequest.ProtoReflect.Descriptor instead.

func (*ValidateVerbCallRequest) GetInputData 

func (x *ValidateVerbCallRequest) GetInputData() *anypb.Any

func (*ValidateVerbCallRequest) GetInterfaceVersion 

func (x *ValidateVerbCallRequest) GetInterfaceVersion() string

func (*ValidateVerbCallRequest) GetStrictValidation 

func (x *ValidateVerbCallRequest) GetStrictValidation() bool

func (*ValidateVerbCallRequest) GetVerbName 

func (x *ValidateVerbCallRequest) GetVerbName() string

func (*ValidateVerbCallRequest) ProtoMessage 

func (*ValidateVerbCallRequest) ProtoMessage()

func (*ValidateVerbCallRequest) ProtoReflect 

func (x *ValidateVerbCallRequest) ProtoReflect() protoreflect.Message

func (*ValidateVerbCallRequest) Reset 

func (x *ValidateVerbCallRequest) Reset()

func (*ValidateVerbCallRequest) String 

func (x *ValidateVerbCallRequest) String() string

type ValidateVerbCallResponse 

type ValidateVerbCallResponse struct {
	Valid       bool     `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	Errors      []string `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	Warnings    []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	Suggestions []string `protobuf:"bytes,4,rep,name=suggestions,proto3" json:"suggestions,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateVerbCallResponse) Descriptor deprecated 

func (*ValidateVerbCallResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValidateVerbCallResponse.ProtoReflect.Descriptor instead.

func (*ValidateVerbCallResponse) GetErrors 

func (x *ValidateVerbCallResponse) GetErrors() []string

func (*ValidateVerbCallResponse) GetSuggestions 

func (x *ValidateVerbCallResponse) GetSuggestions() []string

func (*ValidateVerbCallResponse) GetValid 

func (x *ValidateVerbCallResponse) GetValid() bool

func (*ValidateVerbCallResponse) GetWarnings 

func (x *ValidateVerbCallResponse) GetWarnings() []string

func (*ValidateVerbCallResponse) ProtoMessage 

func (*ValidateVerbCallResponse) ProtoMessage()

func (*ValidateVerbCallResponse) ProtoReflect 

func (x *ValidateVerbCallResponse) ProtoReflect() protoreflect.Message

func (*ValidateVerbCallResponse) Reset 

func (x *ValidateVerbCallResponse) Reset()

func (*ValidateVerbCallResponse) String 

func (x *ValidateVerbCallResponse) String() string

type ValidationConstraint 

type ValidationConstraint struct {
	ConstraintType string   `protobuf:"bytes,1,opt,name=constraint_type,json=constraintType,proto3" json:"constraint_type,omitempty"` // "range", "pattern", "enum", "length", "custom"
	Values         []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	ErrorMessage   string   `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Required       bool     `protobuf:"varint,4,opt,name=required,proto3" json:"required,omitempty"`
	// contains filtered or unexported fields
}

ValidationConstraint defines validation rules for fields

func (*ValidationConstraint) Descriptor deprecated 

func (*ValidationConstraint) Descriptor() ([]byte, []int)

Deprecated: Use ValidationConstraint.ProtoReflect.Descriptor instead.

func (*ValidationConstraint) GetConstraintType 

func (x *ValidationConstraint) GetConstraintType() string

func (*ValidationConstraint) GetErrorMessage 

func (x *ValidationConstraint) GetErrorMessage() string

func (*ValidationConstraint) GetRequired 

func (x *ValidationConstraint) GetRequired() bool

func (*ValidationConstraint) GetValues 

func (x *ValidationConstraint) GetValues() []string

func (*ValidationConstraint) ProtoMessage 

func (*ValidationConstraint) ProtoMessage()

func (*ValidationConstraint) ProtoReflect 

func (x *ValidationConstraint) ProtoReflect() protoreflect.Message

func (*ValidationConstraint) Reset 

func (x *ValidationConstraint) Reset()

func (*ValidationConstraint) String 

func (x *ValidationConstraint) String() string

type Value 

type Value struct {

	// Types that are valid to be assigned to Kind:
	//
	//	*Value_Literal
	//	*Value_FactPath
	//	*Value_ResultSlot
	Kind isValue_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

Value deliberately distinguishes literals, fact paths, and prior results.

func (*Value) Descriptor deprecated 

func (*Value) Descriptor() ([]byte, []int)

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetFactPath 

func (x *Value) GetFactPath() string

func (*Value) GetKind 

func (x *Value) GetKind() isValue_Kind

func (*Value) GetLiteral 

func (x *Value) GetLiteral() *Literal

func (*Value) GetResultSlot 

func (x *Value) GetResultSlot() uint32

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

func (x *Value) ProtoReflect() protoreflect.Message

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type Value_FactPath 

type Value_FactPath struct {
	FactPath string `protobuf:"bytes,2,opt,name=fact_path,json=factPath,proto3,oneof"`
}

type Value_Literal 

type Value_Literal struct {
	Literal *Literal `protobuf:"bytes,1,opt,name=literal,proto3,oneof"`
}

type Value_ResultSlot 

type Value_ResultSlot struct {
	ResultSlot uint32 `protobuf:"varint,3,opt,name=result_slot,json=resultSlot,proto3,oneof"`
}

type VerbCall 

type VerbCall struct {
	VerbName         string                 `protobuf:"bytes,1,opt,name=verb_name,json=verbName,proto3" json:"verb_name,omitempty"`
	InterfaceVersion string                 `protobuf:"bytes,2,opt,name=interface_version,json=interfaceVersion,proto3" json:"interface_version,omitempty"`
	Input            *anypb.Any             `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	RequestedAt      *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=requested_at,json=requestedAt,proto3" json:"requested_at,omitempty"`
	// Execution context
	Context *ExecutionContext `protobuf:"bytes,5,opt,name=context,proto3" json:"context,omitempty"`
	// Tracing information
	TraceId string `protobuf:"bytes,6,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	SpanId  string `protobuf:"bytes,7,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	// contains filtered or unexported fields
}

VerbCall represents a call to a verb with type information

func (*VerbCall) Descriptor deprecated 

func (*VerbCall) Descriptor() ([]byte, []int)

Deprecated: Use VerbCall.ProtoReflect.Descriptor instead.

func (*VerbCall) GetContext 

func (x *VerbCall) GetContext() *ExecutionContext

func (*VerbCall) GetInput 

func (x *VerbCall) GetInput() *anypb.Any

func (*VerbCall) GetInterfaceVersion 

func (x *VerbCall) GetInterfaceVersion() string

func (*VerbCall) GetRequestedAt 

func (x *VerbCall) GetRequestedAt() *timestamppb.Timestamp

func (*VerbCall) GetSpanId 

func (x *VerbCall) GetSpanId() string

func (*VerbCall) GetTraceId 

func (x *VerbCall) GetTraceId() string

func (*VerbCall) GetVerbName 

func (x *VerbCall) GetVerbName() string

func (*VerbCall) ProtoMessage 

func (*VerbCall) ProtoMessage()

func (*VerbCall) ProtoReflect 

func (x *VerbCall) ProtoReflect() protoreflect.Message

func (*VerbCall) Reset 

func (x *VerbCall) Reset()

func (*VerbCall) String 

func (x *VerbCall) String() string

type VerbConstraints 

type VerbConstraints struct {

	// Maximum execution time
	MaxExecutionTimeSeconds int32 `` /* 135-byte string literal not displayed */
	// Resource limits
	ResourceLimits *ResourceLimits `protobuf:"bytes,2,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"`
	// Retry policy
	RetryPolicy *RetryPolicy `protobuf:"bytes,3,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// Idempotency settings
	Idempotent bool `protobuf:"varint,4,opt,name=idempotent,proto3" json:"idempotent,omitempty"`
	// Rate limiting
	RateLimits *RateLimits `protobuf:"bytes,5,opt,name=rate_limits,json=rateLimits,proto3" json:"rate_limits,omitempty"`
	// Security constraints
	Security *SecurityConstraints `protobuf:"bytes,6,opt,name=security,proto3" json:"security,omitempty"`
	// contains filtered or unexported fields
}

VerbConstraints define execution constraints for a verb

func (*VerbConstraints) Descriptor deprecated 

func (*VerbConstraints) Descriptor() ([]byte, []int)

Deprecated: Use VerbConstraints.ProtoReflect.Descriptor instead.

func (*VerbConstraints) GetIdempotent 

func (x *VerbConstraints) GetIdempotent() bool

func (*VerbConstraints) GetMaxExecutionTimeSeconds 

func (x *VerbConstraints) GetMaxExecutionTimeSeconds() int32

func (*VerbConstraints) GetRateLimits 

func (x *VerbConstraints) GetRateLimits() *RateLimits

func (*VerbConstraints) GetResourceLimits 

func (x *VerbConstraints) GetResourceLimits() *ResourceLimits

func (*VerbConstraints) GetRetryPolicy 

func (x *VerbConstraints) GetRetryPolicy() *RetryPolicy

func (*VerbConstraints) GetSecurity 

func (x *VerbConstraints) GetSecurity() *SecurityConstraints

func (*VerbConstraints) ProtoMessage 

func (*VerbConstraints) ProtoMessage()

func (*VerbConstraints) ProtoReflect 

func (x *VerbConstraints) ProtoReflect() protoreflect.Message

func (*VerbConstraints) Reset 

func (x *VerbConstraints) Reset()

func (*VerbConstraints) String 

func (x *VerbConstraints) String() string

type VerbError 

type VerbError struct {
	ErrorCode  int32        `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	ErrorName  string       `protobuf:"bytes,2,opt,name=error_name,json=errorName,proto3" json:"error_name,omitempty"`
	Message    string       `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Details    *anypb.Any   `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"`
	Retryable  bool         `protobuf:"varint,5,opt,name=retryable,proto3" json:"retryable,omitempty"`
	StackTrace string       `protobuf:"bytes,6,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"`
	CausedBy   []*VerbError `protobuf:"bytes,7,rep,name=caused_by,json=causedBy,proto3" json:"caused_by,omitempty"`
	// contains filtered or unexported fields
}

VerbError represents an error from verb execution

func (*VerbError) Descriptor deprecated 

func (*VerbError) Descriptor() ([]byte, []int)

Deprecated: Use VerbError.ProtoReflect.Descriptor instead.

func (*VerbError) GetCausedBy 

func (x *VerbError) GetCausedBy() []*VerbError

func (*VerbError) GetDetails 

func (x *VerbError) GetDetails() *anypb.Any

func (*VerbError) GetErrorCode 

func (x *VerbError) GetErrorCode() int32

func (*VerbError) GetErrorName 

func (x *VerbError) GetErrorName() string

func (*VerbError) GetMessage 

func (x *VerbError) GetMessage() string

func (*VerbError) GetRetryable 

func (x *VerbError) GetRetryable() bool

func (*VerbError) GetStackTrace 

func (x *VerbError) GetStackTrace() string

func (*VerbError) ProtoMessage 

func (*VerbError) ProtoMessage()

func (*VerbError) ProtoReflect 

func (x *VerbError) ProtoReflect() protoreflect.Message

func (*VerbError) Reset 

func (x *VerbError) Reset()

func (*VerbError) String 

func (x *VerbError) String() string

type VerbExample 

type VerbExample struct {
	Name          string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description   string       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	InputExample  *anypb.Any   `protobuf:"bytes,3,opt,name=input_example,json=inputExample,proto3" json:"input_example,omitempty"`
	OutputExample *anypb.Any   `protobuf:"bytes,4,opt,name=output_example,json=outputExample,proto3" json:"output_example,omitempty"`
	ErrorExamples []*anypb.Any `protobuf:"bytes,5,rep,name=error_examples,json=errorExamples,proto3" json:"error_examples,omitempty"`
	Scenario      string       `protobuf:"bytes,6,opt,name=scenario,proto3" json:"scenario,omitempty"`
	// contains filtered or unexported fields
}

VerbExample provides examples of verb usage

func (*VerbExample) Descriptor deprecated 

func (*VerbExample) Descriptor() ([]byte, []int)

Deprecated: Use VerbExample.ProtoReflect.Descriptor instead.

func (*VerbExample) GetDescription 

func (x *VerbExample) GetDescription() string

func (*VerbExample) GetErrorExamples 

func (x *VerbExample) GetErrorExamples() []*anypb.Any

func (*VerbExample) GetInputExample 

func (x *VerbExample) GetInputExample() *anypb.Any

func (*VerbExample) GetName 

func (x *VerbExample) GetName() string

func (*VerbExample) GetOutputExample 

func (x *VerbExample) GetOutputExample() *anypb.Any

func (*VerbExample) GetScenario 

func (x *VerbExample) GetScenario() string

func (*VerbExample) ProtoMessage 

func (*VerbExample) ProtoMessage()

func (*VerbExample) ProtoReflect 

func (x *VerbExample) ProtoReflect() protoreflect.Message

func (*VerbExample) Reset 

func (x *VerbExample) Reset()

func (*VerbExample) String 

func (x *VerbExample) String() string

type VerbExecutionStatus 

type VerbExecutionStatus int32

VerbExecutionStatus represents the status of verb execution 

const (
	VerbExecutionStatus_VERB_EXECUTION_STATUS_UNSPECIFIED       VerbExecutionStatus = 0
	VerbExecutionStatus_VERB_EXECUTION_STATUS_SUCCESS           VerbExecutionStatus = 1
	VerbExecutionStatus_VERB_EXECUTION_STATUS_ERROR             VerbExecutionStatus = 2
	VerbExecutionStatus_VERB_EXECUTION_STATUS_TIMEOUT           VerbExecutionStatus = 3
	VerbExecutionStatus_VERB_EXECUTION_STATUS_CANCELLED         VerbExecutionStatus = 4
	VerbExecutionStatus_VERB_EXECUTION_STATUS_RATE_LIMITED      VerbExecutionStatus = 5
	VerbExecutionStatus_VERB_EXECUTION_STATUS_CAPABILITY_DENIED VerbExecutionStatus = 6
)

func (VerbExecutionStatus) Descriptor 

func (VerbExecutionStatus) Descriptor() protoreflect.EnumDescriptor

func (VerbExecutionStatus) Enum 

func (x VerbExecutionStatus) Enum() *VerbExecutionStatus

func (VerbExecutionStatus) EnumDescriptor deprecated 

func (VerbExecutionStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use VerbExecutionStatus.Descriptor instead.

func (VerbExecutionStatus) Number 

func (x VerbExecutionStatus) Number() protoreflect.EnumNumber

func (VerbExecutionStatus) String 

func (x VerbExecutionStatus) String() string

func (VerbExecutionStatus) Type 

func (VerbExecutionStatus) Type() protoreflect.EnumType

type VerbInterface 

type VerbInterface struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version     string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Buf-managed semantic version
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Input and output schemas
	InputSchema  *Schema `protobuf:"bytes,4,opt,name=input_schema,json=inputSchema,proto3" json:"input_schema,omitempty"`
	OutputSchema *Schema `protobuf:"bytes,5,opt,name=output_schema,json=outputSchema,proto3" json:"output_schema,omitempty"`
	// Capability required to execute this verb
	RequiredCapability string `protobuf:"bytes,6,opt,name=required_capability,json=requiredCapability,proto3" json:"required_capability,omitempty"`
	// Execution constraints
	Constraints *VerbConstraints `protobuf:"bytes,7,opt,name=constraints,proto3" json:"constraints,omitempty"`
	// Error definitions
	ErrorDefinitions []*ErrorDefinition `protobuf:"bytes,8,rep,name=error_definitions,json=errorDefinitions,proto3" json:"error_definitions,omitempty"`
	// Documentation and examples
	Documentation string         `protobuf:"bytes,9,opt,name=documentation,proto3" json:"documentation,omitempty"`
	Examples      []*VerbExample `protobuf:"bytes,10,rep,name=examples,proto3" json:"examples,omitempty"`
	// Buf schema registry information
	BufModule string                 `protobuf:"bytes,11,opt,name=buf_module,json=bufModule,proto3" json:"buf_module,omitempty"`
	BufCommit string                 `protobuf:"bytes,12,opt,name=buf_commit,json=bufCommit,proto3" json:"buf_commit,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Compatibility information
	Compatibility *CompatibilityInfo `protobuf:"bytes,15,opt,name=compatibility,proto3" json:"compatibility,omitempty"`
	// Tags for categorization and discovery
	Tags []string `protobuf:"bytes,16,rep,name=tags,proto3" json:"tags,omitempty"`
	// Metadata
	Metadata map[string]string `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

VerbInterface defines the interface contract for a verb

func (*VerbInterface) Descriptor deprecated 

func (*VerbInterface) Descriptor() ([]byte, []int)

Deprecated: Use VerbInterface.ProtoReflect.Descriptor instead.

func (*VerbInterface) GetBufCommit 

func (x *VerbInterface) GetBufCommit() string

func (*VerbInterface) GetBufModule 

func (x *VerbInterface) GetBufModule() string

func (*VerbInterface) GetCompatibility 

func (x *VerbInterface) GetCompatibility() *CompatibilityInfo

func (*VerbInterface) GetConstraints 

func (x *VerbInterface) GetConstraints() *VerbConstraints

func (*VerbInterface) GetCreatedAt 

func (x *VerbInterface) GetCreatedAt() *timestamppb.Timestamp

func (*VerbInterface) GetDescription 

func (x *VerbInterface) GetDescription() string

func (*VerbInterface) GetDocumentation 

func (x *VerbInterface) GetDocumentation() string

func (*VerbInterface) GetErrorDefinitions 

func (x *VerbInterface) GetErrorDefinitions() []*ErrorDefinition

func (*VerbInterface) GetExamples 

func (x *VerbInterface) GetExamples() []*VerbExample

func (*VerbInterface) GetInputSchema 

func (x *VerbInterface) GetInputSchema() *Schema

func (*VerbInterface) GetMetadata 

func (x *VerbInterface) GetMetadata() map[string]string

func (*VerbInterface) GetName 

func (x *VerbInterface) GetName() string

func (*VerbInterface) GetOutputSchema 

func (x *VerbInterface) GetOutputSchema() *Schema

func (*VerbInterface) GetRequiredCapability 

func (x *VerbInterface) GetRequiredCapability() string

func (*VerbInterface) GetTags 

func (x *VerbInterface) GetTags() []string

func (*VerbInterface) GetUpdatedAt 

func (x *VerbInterface) GetUpdatedAt() *timestamppb.Timestamp

func (*VerbInterface) GetVersion 

func (x *VerbInterface) GetVersion() string

func (*VerbInterface) ProtoMessage 

func (*VerbInterface) ProtoMessage()

func (*VerbInterface) ProtoReflect 

func (x *VerbInterface) ProtoReflect() protoreflect.Message

func (*VerbInterface) Reset 

func (x *VerbInterface) Reset()

func (*VerbInterface) String 

func (x *VerbInterface) String() string

type VerbRegistry 

type VerbRegistry struct {
	Interfaces      map[string]*VerbInterface `` /* 147-byte string literal not displayed */
	RegistryVersion string                    `protobuf:"bytes,2,opt,name=registry_version,json=registryVersion,proto3" json:"registry_version,omitempty"`
	LastUpdated     *timestamppb.Timestamp    `protobuf:"bytes,3,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	// Buf registry integration
	BufModule string `protobuf:"bytes,4,opt,name=buf_module,json=bufModule,proto3" json:"buf_module,omitempty"`
	BufCommit string `protobuf:"bytes,5,opt,name=buf_commit,json=bufCommit,proto3" json:"buf_commit,omitempty"`
	// Interface evolution tracking
	InterfaceEvolution map[string]*InterfaceEvolution `` /* 189-byte string literal not displayed */
	// contains filtered or unexported fields
}

VerbRegistry manages the registry of all verb interfaces

func (*VerbRegistry) Descriptor deprecated 

func (*VerbRegistry) Descriptor() ([]byte, []int)

Deprecated: Use VerbRegistry.ProtoReflect.Descriptor instead.

func (*VerbRegistry) GetBufCommit 

func (x *VerbRegistry) GetBufCommit() string

func (*VerbRegistry) GetBufModule 

func (x *VerbRegistry) GetBufModule() string

func (*VerbRegistry) GetInterfaceEvolution 

func (x *VerbRegistry) GetInterfaceEvolution() map[string]*InterfaceEvolution

func (*VerbRegistry) GetInterfaces 

func (x *VerbRegistry) GetInterfaces() map[string]*VerbInterface

func (*VerbRegistry) GetLastUpdated 

func (x *VerbRegistry) GetLastUpdated() *timestamppb.Timestamp

func (*VerbRegistry) GetRegistryVersion 

func (x *VerbRegistry) GetRegistryVersion() string

func (*VerbRegistry) ProtoMessage 

func (*VerbRegistry) ProtoMessage()

func (*VerbRegistry) ProtoReflect 

func (x *VerbRegistry) ProtoReflect() protoreflect.Message

func (*VerbRegistry) Reset 

func (x *VerbRegistry) Reset()

func (*VerbRegistry) String 

func (x *VerbRegistry) String() string

type VerbRegistryServiceClient 

type VerbRegistryServiceClient interface {
	// RegisterVerbInterface registers a new verb interface
	RegisterVerbInterface(ctx context.Context, in *RegisterVerbInterfaceRequest, opts ...grpc.CallOption) (*RegisterVerbInterfaceResponse, error)
	// GetVerbInterface retrieves a verb interface by name and version
	GetVerbInterface(ctx context.Context, in *GetVerbInterfaceRequest, opts ...grpc.CallOption) (*GetVerbInterfaceResponse, error)
	// ListVerbInterfaces lists all registered verb interfaces
	ListVerbInterfaces(ctx context.Context, in *ListVerbInterfacesRequest, opts ...grpc.CallOption) (*ListVerbInterfacesResponse, error)
	// ValidateVerbCall validates a verb call against its interface
	ValidateVerbCall(ctx context.Context, in *ValidateVerbCallRequest, opts ...grpc.CallOption) (*ValidateVerbCallResponse, error)
	// CheckInterfaceCompatibility checks if interface changes are backward compatible
	CheckInterfaceCompatibility(ctx context.Context, in *CheckInterfaceCompatibilityRequest, opts ...grpc.CallOption) (*CheckInterfaceCompatibilityResponse, error)
	// GenerateVerbCode generates implementation stubs for verb interfaces
	GenerateVerbCode(ctx context.Context, in *GenerateVerbCodeRequest, opts ...grpc.CallOption) (*GenerateVerbCodeResponse, error)
}

VerbRegistryServiceClient is the client API for VerbRegistryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

VerbRegistryService manages verb interface definitions and evolution

func NewVerbRegistryServiceClient 

func NewVerbRegistryServiceClient(cc grpc.ClientConnInterface) VerbRegistryServiceClient

type VerbRegistryServiceServer 

type VerbRegistryServiceServer interface {
	// RegisterVerbInterface registers a new verb interface
	RegisterVerbInterface(context.Context, *RegisterVerbInterfaceRequest) (*RegisterVerbInterfaceResponse, error)
	// GetVerbInterface retrieves a verb interface by name and version
	GetVerbInterface(context.Context, *GetVerbInterfaceRequest) (*GetVerbInterfaceResponse, error)
	// ListVerbInterfaces lists all registered verb interfaces
	ListVerbInterfaces(context.Context, *ListVerbInterfacesRequest) (*ListVerbInterfacesResponse, error)
	// ValidateVerbCall validates a verb call against its interface
	ValidateVerbCall(context.Context, *ValidateVerbCallRequest) (*ValidateVerbCallResponse, error)
	// CheckInterfaceCompatibility checks if interface changes are backward compatible
	CheckInterfaceCompatibility(context.Context, *CheckInterfaceCompatibilityRequest) (*CheckInterfaceCompatibilityResponse, error)
	// GenerateVerbCode generates implementation stubs for verb interfaces
	GenerateVerbCode(context.Context, *GenerateVerbCodeRequest) (*GenerateVerbCodeResponse, error)
	// contains filtered or unexported methods
}

VerbRegistryServiceServer is the server API for VerbRegistryService service. All implementations must embed UnimplementedVerbRegistryServiceServer for forward compatibility.

VerbRegistryService manages verb interface definitions and evolution

type VerbResult 

type VerbResult struct {
	VerbName         string              `protobuf:"bytes,1,opt,name=verb_name,json=verbName,proto3" json:"verb_name,omitempty"`
	InterfaceVersion string              `protobuf:"bytes,2,opt,name=interface_version,json=interfaceVersion,proto3" json:"interface_version,omitempty"`
	Output           *anypb.Any          `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	Status           VerbExecutionStatus `protobuf:"varint,4,opt,name=status,proto3,enum=effectus.v1.VerbExecutionStatus" json:"status,omitempty"`
	// Timing information
	StartedAt           *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	CompletedAt         *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	ExecutionDurationMs int64                  `protobuf:"varint,7,opt,name=execution_duration_ms,json=executionDurationMs,proto3" json:"execution_duration_ms,omitempty"`
	// Error information (if status is ERROR)
	Error *VerbError `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	// Resource usage
	ResourceUsage *ResourceUsage `protobuf:"bytes,9,opt,name=resource_usage,json=resourceUsage,proto3" json:"resource_usage,omitempty"`
	// Tracing information
	TraceId string `protobuf:"bytes,10,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	SpanId  string `protobuf:"bytes,11,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	// contains filtered or unexported fields
}

VerbResult represents the result of a verb execution

func (*VerbResult) Descriptor deprecated 

func (*VerbResult) Descriptor() ([]byte, []int)

Deprecated: Use VerbResult.ProtoReflect.Descriptor instead.

func (*VerbResult) GetCompletedAt 

func (x *VerbResult) GetCompletedAt() *timestamppb.Timestamp

func (*VerbResult) GetError 

func (x *VerbResult) GetError() *VerbError

func (*VerbResult) GetExecutionDurationMs 

func (x *VerbResult) GetExecutionDurationMs() int64

func (*VerbResult) GetInterfaceVersion 

func (x *VerbResult) GetInterfaceVersion() string

func (*VerbResult) GetOutput 

func (x *VerbResult) GetOutput() *anypb.Any

func (*VerbResult) GetResourceUsage 

func (x *VerbResult) GetResourceUsage() *ResourceUsage

func (*VerbResult) GetSpanId 

func (x *VerbResult) GetSpanId() string

func (*VerbResult) GetStartedAt 

func (x *VerbResult) GetStartedAt() *timestamppb.Timestamp

func (*VerbResult) GetStatus 

func (x *VerbResult) GetStatus() VerbExecutionStatus

func (*VerbResult) GetTraceId 

func (x *VerbResult) GetTraceId() string

func (*VerbResult) GetVerbName 

func (x *VerbResult) GetVerbName() string

func (*VerbResult) ProtoMessage 

func (*VerbResult) ProtoMessage()

func (*VerbResult) ProtoReflect 

func (x *VerbResult) ProtoReflect() protoreflect.Message

func (*VerbResult) Reset 

func (x *VerbResult) Reset()

func (*VerbResult) String 

func (x *VerbResult) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.