proto

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 13, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TypeFieldOffset    = 0
	MessageTypeOffset  = 0
	ByteSizeInBytes    = 1
	BooleanSizeInBytes = 1
	ShortSizeInBytes   = 2
	CharSizeInBytes    = 2
	IntSizeInBytes     = 4
	FloatSizeInBytes   = 4
	LongSizeInBytes    = 8
	DoubleSizeInBytes  = 8
	UUIDSizeInBytes    = 17
	UuidSizeInBytes    = 17
	EntrySizeInBytes   = UUIDSizeInBytes + LongSizeInBytes

	CorrelationIDFieldOffset   = TypeFieldOffset + IntSizeInBytes
	CorrelationIDOffset        = MessageTypeOffset + IntSizeInBytes
	FragmentationIDOffset      = 0
	PartitionIDOffset          = CorrelationIDOffset + LongSizeInBytes
	RequestThreadIdOffset      = PartitionIDOffset + IntSizeInBytes
	RequestTtlOffset           = RequestThreadIdOffset + LongSizeInBytes
	RequestIncludeValueOffset  = PartitionIDOffset + IntSizeInBytes
	RequestListenerFlagsOffset = RequestIncludeValueOffset + BooleanSizeInBytes
	RequestLocalOnlyOffset     = RequestListenerFlagsOffset + IntSizeInBytes
	RequestReferenceIdOffset   = RequestTtlOffset + LongSizeInBytes
	ResponseBackupAcksOffset   = CorrelationIDOffset + LongSizeInBytes
	UnfragmentedMessage        = BeginFragmentFlag | EndFragmentFlag

	DefaultFlags              = 0
	BeginFragmentFlag         = 1 << 15
	EndFragmentFlag           = 1 << 14
	IsFinalFlag               = 1 << 13
	BeginDataStructureFlag    = 1 << 12
	EndDataStructureFlag      = 1 << 11
	IsNullFlag                = 1 << 10
	IsEventFlag               = 1 << 9
	BackupEventFlag           = 1 << 7
	SizeOfFrameLengthAndFlags = IntSizeInBytes + ShortSizeInBytes
)

Variables

View Source 
var (
	//EmptyArray = make([]byte, 0)
	NullFrame  = NewFrameWith([]byte{}, IsNullFlag)
	BeginFrame = NewFrameWith([]byte{}, BeginDataStructureFlag)
	EndFrame   = NewFrameWith([]byte{}, EndDataStructureFlag)
)

Functions

func NewStackTraceElement added in v1.0.0 

func NewStackTraceElement(className, methodName, fileName string, lineNumber int32) hzerrors.StackTraceElement

Types

type ClientMessage 

type ClientMessage struct {
	Err       error
	Frames    []*Frame
	Retryable bool
}

ClientMessage

func NewClientMessage 

func NewClientMessage(startFrame *Frame) *ClientMessage

func NewClientMessageForDecode added in v1.0.0 

func NewClientMessageForDecode(frame *Frame) *ClientMessage

func NewClientMessageForEncode added in v1.0.0 

func NewClientMessageForEncode() *ClientMessage

func (*ClientMessage) AddFrame added in v1.0.0 

func (m *ClientMessage) AddFrame(frame *Frame)

func (*ClientMessage) Copy added in v1.0.0 

func (m *ClientMessage) Copy() *ClientMessage

func (*ClientMessage) CorrelationID 

func (m *ClientMessage) CorrelationID() int64

func (*ClientMessage) DropFragmentationFrame added in v1.0.0 

func (m *ClientMessage) DropFragmentationFrame()

func (*ClientMessage) FragmentationID added in v1.0.0 

func (m *ClientMessage) FragmentationID() int64

func (*ClientMessage) FrameIterator added in v1.0.0 

func (m *ClientMessage) FrameIterator() *ForwardFrameIterator

func (*ClientMessage) HasBackupEventFlag added in v1.0.0 

func (m *ClientMessage) HasBackupEventFlag() bool

func (*ClientMessage) HasEventFlag added in v1.0.0 

func (m *ClientMessage) HasEventFlag() bool

func (*ClientMessage) HasFinalFrame added in v1.0.0 

func (m *ClientMessage) HasFinalFrame() bool

func (*ClientMessage) HasUnFragmentedMessageFlags added in v1.0.0 

func (m *ClientMessage) HasUnFragmentedMessageFlags() bool

func (*ClientMessage) NumberOfBackupAcks added in v1.0.0 

func (m *ClientMessage) NumberOfBackupAcks() uint8

func (*ClientMessage) PartitionID 

func (m *ClientMessage) PartitionID() int32

func (*ClientMessage) SetCorrelationID 

func (m *ClientMessage) SetCorrelationID(correlationID int64)

func (*ClientMessage) SetMessageType 

func (m *ClientMessage) SetMessageType(messageType int32)

func (*ClientMessage) SetPartitionId added in v1.0.0 

func (m *ClientMessage) SetPartitionId(partitionId int32)

func (*ClientMessage) SetRetryable added in v1.0.0 

func (m *ClientMessage) SetRetryable(retryable bool)

func (*ClientMessage) TotalLength added in v1.0.0 

func (m *ClientMessage) TotalLength() int

func (*ClientMessage) Type added in v1.0.0 

func (m *ClientMessage) Type() int32

func (*ClientMessage) Write added in v1.0.0 

func (m *ClientMessage) Write(w io.Writer) error

type ClientMessageHandler added in v1.0.0 

type ClientMessageHandler func(clientMessage *ClientMessage)

type ErrorHolder added in v1.0.0 

type ErrorHolder struct {
	ClassName          string
	Message            string
	StackTraceElements []hzerrors.StackTraceElement
	ErrorCode          int32
}

func NewErrorHolder added in v1.0.0 

func NewErrorHolder(errorCode int32, className, message string, stackTraceElements []hzerrors.StackTraceElement) ErrorHolder

type ForwardFrameIterator added in v1.0.0 

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

ForwardFrameIterator

func NewForwardFrameIterator added in v1.0.0 

func NewForwardFrameIterator(frames []*Frame) *ForwardFrameIterator

func (*ForwardFrameIterator) HasNext added in v1.0.0 

func (it *ForwardFrameIterator) HasNext() bool

func (*ForwardFrameIterator) Next added in v1.0.0 

func (it *ForwardFrameIterator) Next() *Frame

func (*ForwardFrameIterator) PeekNext added in v1.0.0 

func (it *ForwardFrameIterator) PeekNext() *Frame

type Frame added in v1.0.0 

type Frame struct {
	Content []byte
	// contains filtered or unexported fields
}

func NewBeginFrame added in v1.0.0 

func NewBeginFrame() *Frame

func NewEndFrame added in v1.0.0 

func NewEndFrame() *Frame

func NewFrame added in v1.0.0 

func NewFrame(content []byte) *Frame

NewFrame creates a Frame with content

func NewFrameWith added in v1.0.0 

func NewFrameWith(content []byte, flags uint16) *Frame

NewFrameWith creates a Frame with content and flags

func NewNullFrame added in v1.0.0 

func NewNullFrame() *Frame

func (*Frame) Copy added in v1.0.0 

func (frame *Frame) Copy() *Frame

Copy frame

func (*Frame) DeepCopy added in v1.0.0 

func (frame *Frame) DeepCopy() *Frame

func (Frame) GetLength added in v1.0.0 

func (frame Frame) GetLength() int

func (Frame) HasBackupEventFlag added in v1.0.0 

func (frame Frame) HasBackupEventFlag() bool

func (Frame) HasBeginFragmentFlag added in v1.0.0 

func (frame Frame) HasBeginFragmentFlag() bool

func (Frame) HasEndFragmentFlag added in v1.0.0 

func (frame Frame) HasEndFragmentFlag() bool

func (Frame) HasEventFlag added in v1.0.0 

func (frame Frame) HasEventFlag() bool

func (Frame) HasUnFragmentedMessageFlags added in v1.0.0 

func (frame Frame) HasUnFragmentedMessageFlags() bool

func (Frame) IsBeginFrame added in v1.0.0 

func (frame Frame) IsBeginFrame() bool

func (Frame) IsEndFrame added in v1.0.0 

func (frame Frame) IsEndFrame() bool

IsEndFrame returns true if this is the last frame

func (Frame) IsFinalFrame added in v1.0.0 

func (frame Frame) IsFinalFrame() bool

func (Frame) IsFlagSet added in v1.0.0 

func (frame Frame) IsFlagSet(flagMask uint16) bool

func (Frame) IsNullFrame added in v1.0.0 

func (frame Frame) IsNullFrame() bool

type Pair 

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

func NewPair 

func NewPair(key, value interface{}) Pair

TODO: remove NewPair

func (Pair) Key 

func (p Pair) Key() interface{}

TODO: remove Key()

func (Pair) Value 

func (p Pair) Value() interface{}

TODO: remove Value()

Source Files

View all Source files

Directories

Path Synopsis
* Copyright (c) 2008-2021, Hazelcast, Inc.
 * Copyright (c) 2008-2021, Hazelcast, Inc.

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.