bridge

package
v2.2.2-0...-90f574e Latest Latest
Warning

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

Go to latest
Published: Feb 17, 2020 License: MIT Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthBridge        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBridge          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBridge = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type ActorPID

type ActorPID struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Id      string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
}

func (*ActorPID) Descriptor

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

func (*ActorPID) GetAddress

func (m *ActorPID) GetAddress() string

func (*ActorPID) GetId

func (m *ActorPID) GetId() string

func (*ActorPID) Marshal

func (m *ActorPID) Marshal() (dAtA []byte, err error)

func (*ActorPID) MarshalTo

func (m *ActorPID) MarshalTo(dAtA []byte) (int, error)

func (*ActorPID) MarshalToSizedBuffer

func (m *ActorPID) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActorPID) ProtoMessage

func (*ActorPID) ProtoMessage()

func (*ActorPID) Reset

func (m *ActorPID) Reset()

func (*ActorPID) Size

func (m *ActorPID) Size() (n int)

func (*ActorPID) String

func (m *ActorPID) String() string

func (*ActorPID) Unmarshal

func (m *ActorPID) Unmarshal(dAtA []byte) error

func (*ActorPID) XXX_DiscardUnknown

func (m *ActorPID) XXX_DiscardUnknown()

func (*ActorPID) XXX_Marshal

func (m *ActorPID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActorPID) XXX_Merge

func (m *ActorPID) XXX_Merge(src proto.Message)

func (*ActorPID) XXX_Size

func (m *ActorPID) XXX_Size() int

func (*ActorPID) XXX_Unmarshal

func (m *ActorPID) XXX_Unmarshal(b []byte) error

type WireDelivery

type WireDelivery struct {
	Header   map[string]string `` /* 153-byte string literal not displayed */
	Message  *types.Any        `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Target   *ActorPID         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Sender   *ActorPID         `protobuf:"bytes,4,opt,name=sender,proto3" json:"sender,omitempty"`
	Outgoing bool              `protobuf:"varint,5,opt,name=outgoing,proto3" json:"outgoing,omitempty"`
	Tracing  map[string]string `` /* 155-byte string literal not displayed */
}

func (*WireDelivery) Descriptor

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

func (*WireDelivery) GetHeader

func (m *WireDelivery) GetHeader() map[string]string

func (*WireDelivery) GetMessage

func (m *WireDelivery) GetMessage() *types.Any

func (*WireDelivery) GetOutgoing

func (m *WireDelivery) GetOutgoing() bool

func (*WireDelivery) GetSender

func (m *WireDelivery) GetSender() *ActorPID

func (*WireDelivery) GetTarget

func (m *WireDelivery) GetTarget() *ActorPID

func (*WireDelivery) GetTracing

func (m *WireDelivery) GetTracing() map[string]string

func (*WireDelivery) Marshal

func (m *WireDelivery) Marshal() (dAtA []byte, err error)

func (*WireDelivery) MarshalTo

func (m *WireDelivery) MarshalTo(dAtA []byte) (int, error)

func (*WireDelivery) MarshalToSizedBuffer

func (m *WireDelivery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WireDelivery) ProtoMessage

func (*WireDelivery) ProtoMessage()

func (*WireDelivery) Reset

func (m *WireDelivery) Reset()

func (*WireDelivery) Size

func (m *WireDelivery) Size() (n int)

func (*WireDelivery) String

func (m *WireDelivery) String() string

func (*WireDelivery) Unmarshal

func (m *WireDelivery) Unmarshal(dAtA []byte) error

func (*WireDelivery) XXX_DiscardUnknown

func (m *WireDelivery) XXX_DiscardUnknown()

func (*WireDelivery) XXX_Marshal

func (m *WireDelivery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WireDelivery) XXX_Merge

func (m *WireDelivery) XXX_Merge(src proto.Message)

func (*WireDelivery) XXX_Size

func (m *WireDelivery) XXX_Size() int

func (*WireDelivery) XXX_Unmarshal

func (m *WireDelivery) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

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