types

package
v2.12.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2024 License: MIT Imports: 6 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	DefaultRegistrationRefreshMs = 30_000
	DefaultRegistrationExpiryMs  = 120_000
	DefaultMessageExpiryMs       = 120_000
)
View Source 
const (
	MethodRegisterTrigger   = "RegisterTrigger"
	MethodUnRegisterTrigger = "UnregisterTrigger"
	MethodTriggerEvent      = "TriggerEvent"
)

Variables

View Source 
var (
	Error_name = map[int32]string{
		0: "OK",
		1: "VALIDATION_FAILED",
		2: "CAPABILITY_NOT_FOUND",
	}
	Error_value = map[string]int32{
		"OK":                   0,
		"VALIDATION_FAILED":    1,
		"CAPABILITY_NOT_FOUND": 2,
	}
)

Enum value maps for Error.

View Source 
var File_core_capabilities_remote_types_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Aggregator 

type Aggregator interface {
	Aggregate(eventID string, responses [][]byte) (commoncap.CapabilityResponse, error)
}

type DON 

type DON struct {
	ID      string
	Members []p2ptypes.PeerID
	F       uint8
}

NOTE: this type will become part of the Registry (KS-108)

type Dispatcher 

type Dispatcher interface {
	SetReceiver(capabilityId string, donId string, receiver Receiver) error
	RemoveReceiver(capabilityId string, donId string)
	Send(peerID p2ptypes.PeerID, msgBody *MessageBody) error
}

type Error 

type Error int32
const (
	Error_OK                   Error = 0
	Error_VALIDATION_FAILED    Error = 1
	Error_CAPABILITY_NOT_FOUND Error = 2
)

func (Error) Descriptor 

func (Error) Descriptor() protoreflect.EnumDescriptor

func (Error) Enum 

func (x Error) Enum() *Error

func (Error) EnumDescriptor deprecated 

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

Deprecated: Use Error.Descriptor instead.

func (Error) Number 

func (x Error) Number() protoreflect.EnumNumber

func (Error) String 

func (x Error) String() string

func (Error) Type 

func (Error) Type() protoreflect.EnumType

type Message 

type Message struct {
	Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	Body      []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // proto-encoded MessageBody to sign
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetBody 

func (x *Message) GetBody() []byte

func (*Message) GetSignature 

func (x *Message) GetSignature() []byte

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageBody 

type MessageBody struct {

	// header fields set and validated by the Dispatcher
	Version         uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Sender          []byte `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	Receiver        []byte `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"`
	Timestamp       int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	MessageId       []byte `protobuf:"bytes,5,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` // scoped to sender
	CapabilityId    string `protobuf:"bytes,6,opt,name=capability_id,json=capabilityId,proto3" json:"capability_id,omitempty"`
	CapabilityDonId string `protobuf:"bytes,7,opt,name=capability_don_id,json=capabilityDonId,proto3" json:"capability_don_id,omitempty"`
	CallerDonId     string `protobuf:"bytes,8,opt,name=caller_don_id,json=callerDonId,proto3" json:"caller_don_id,omitempty"`
	Method          string `protobuf:"bytes,9,opt,name=method,proto3" json:"method,omitempty"`
	Error           Error  `protobuf:"varint,10,opt,name=error,proto3,enum=remote.Error" json:"error,omitempty"`
	// payload contains a CapabilityRequest or CapabilityResponse
	Payload []byte `protobuf:"bytes,11,opt,name=payload,proto3" json:"payload,omitempty"`
	// Types that are assignable to Metadata:
	//	*MessageBody_TriggerRegistrationMetadata
	//	*MessageBody_TriggerEventMetadata
	Metadata isMessageBody_Metadata `protobuf_oneof:"metadata"`
	// contains filtered or unexported fields
}

func (*MessageBody) Descriptor deprecated 

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

Deprecated: Use MessageBody.ProtoReflect.Descriptor instead.

func (*MessageBody) GetCallerDonId 

func (x *MessageBody) GetCallerDonId() string

func (*MessageBody) GetCapabilityDonId 

func (x *MessageBody) GetCapabilityDonId() string

func (*MessageBody) GetCapabilityId 

func (x *MessageBody) GetCapabilityId() string

func (*MessageBody) GetError 

func (x *MessageBody) GetError() Error

func (*MessageBody) GetMessageId 

func (x *MessageBody) GetMessageId() []byte

func (*MessageBody) GetMetadata 

func (m *MessageBody) GetMetadata() isMessageBody_Metadata

func (*MessageBody) GetMethod 

func (x *MessageBody) GetMethod() string

func (*MessageBody) GetPayload 

func (x *MessageBody) GetPayload() []byte

func (*MessageBody) GetReceiver 

func (x *MessageBody) GetReceiver() []byte

func (*MessageBody) GetSender 

func (x *MessageBody) GetSender() []byte

func (*MessageBody) GetTimestamp 

func (x *MessageBody) GetTimestamp() int64

func (*MessageBody) GetTriggerEventMetadata 

func (x *MessageBody) GetTriggerEventMetadata() *TriggerEventMetadata

func (*MessageBody) GetTriggerRegistrationMetadata 

func (x *MessageBody) GetTriggerRegistrationMetadata() *TriggerRegistrationMetadata

func (*MessageBody) GetVersion 

func (x *MessageBody) GetVersion() uint32

func (*MessageBody) ProtoMessage 

func (*MessageBody) ProtoMessage()

func (*MessageBody) ProtoReflect 

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

func (*MessageBody) Reset 

func (x *MessageBody) Reset()

func (*MessageBody) String 

func (x *MessageBody) String() string

type MessageBody_TriggerEventMetadata 

type MessageBody_TriggerEventMetadata struct {
	TriggerEventMetadata *TriggerEventMetadata `protobuf:"bytes,13,opt,name=trigger_event_metadata,json=triggerEventMetadata,proto3,oneof"`
}

type MessageBody_TriggerRegistrationMetadata 

type MessageBody_TriggerRegistrationMetadata struct {
	TriggerRegistrationMetadata *TriggerRegistrationMetadata `protobuf:"bytes,12,opt,name=trigger_registration_metadata,json=triggerRegistrationMetadata,proto3,oneof"`
}

type Receiver 

type Receiver interface {
	Receive(msg *MessageBody)
}

type RemoteTriggerConfig 

type RemoteTriggerConfig struct {
	RegistrationRefreshMs   uint32
	RegistrationExpiryMs    uint32
	MinResponsesToAggregate uint32
	MessageExpiryMs         uint32
}

NOTE: consider splitting this config into values stored in Registry (KS-118) and values defined locally by Capability owners.

func (*RemoteTriggerConfig) ApplyDefaults 

func (c *RemoteTriggerConfig) ApplyDefaults()

type TriggerEventMetadata 

type TriggerEventMetadata struct {
	TriggerEventId string   `protobuf:"bytes,1,opt,name=trigger_event_id,json=triggerEventId,proto3" json:"trigger_event_id,omitempty"`
	WorkflowIds    []string `protobuf:"bytes,2,rep,name=workflow_ids,json=workflowIds,proto3" json:"workflow_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerEventMetadata) Descriptor deprecated 

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

Deprecated: Use TriggerEventMetadata.ProtoReflect.Descriptor instead.

func (*TriggerEventMetadata) GetTriggerEventId 

func (x *TriggerEventMetadata) GetTriggerEventId() string

func (*TriggerEventMetadata) GetWorkflowIds 

func (x *TriggerEventMetadata) GetWorkflowIds() []string

func (*TriggerEventMetadata) ProtoMessage 

func (*TriggerEventMetadata) ProtoMessage()

func (*TriggerEventMetadata) ProtoReflect 

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

func (*TriggerEventMetadata) Reset 

func (x *TriggerEventMetadata) Reset()

func (*TriggerEventMetadata) String 

func (x *TriggerEventMetadata) String() string

type TriggerRegistrationMetadata 

type TriggerRegistrationMetadata struct {
	LastReceivedEventId string `protobuf:"bytes,1,opt,name=last_received_event_id,json=lastReceivedEventId,proto3" json:"last_received_event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerRegistrationMetadata) Descriptor deprecated 

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

Deprecated: Use TriggerRegistrationMetadata.ProtoReflect.Descriptor instead.

func (*TriggerRegistrationMetadata) GetLastReceivedEventId 

func (x *TriggerRegistrationMetadata) GetLastReceivedEventId() string

func (*TriggerRegistrationMetadata) ProtoMessage 

func (*TriggerRegistrationMetadata) ProtoMessage()

func (*TriggerRegistrationMetadata) ProtoReflect 

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

func (*TriggerRegistrationMetadata) Reset 

func (x *TriggerRegistrationMetadata) Reset()

func (*TriggerRegistrationMetadata) String 

func (x *TriggerRegistrationMetadata) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.