invocation

Documentation

Index

• Constants
• Variables
• type GroupLostEvent
  • func NewGroupLost(groupID int64, err error) *GroupLostEvent
  • func (e *GroupLostEvent) EventName() string
• type Handler
• type Impl
  • func NewImpl(clientMessage *proto.ClientMessage, partitionID int32, ...) *Impl
  • func (i *Impl) Address() pubcluster.Address
  • func (i *Impl) CanRetry(err error) bool
  • func (i *Impl) Close()
  • func (i *Impl) Complete(message *proto.ClientMessage)
  • func (i *Impl) Completed() bool
  • func (i *Impl) Deadline() time.Time
  • func (i *Impl) EventHandler() proto.ClientMessageHandler
  • func (i *Impl) Get() (*proto.ClientMessage, error)
  • func (i *Impl) GetWithContext(ctx context.Context) (*proto.ClientMessage, error)
  • func (i *Impl) Group() int64
  • func (i *Impl) MaybeCanRetry(err error) bool
  • func (i *Impl) PartitionID() int32
  • func (i *Impl) Request() *proto.ClientMessage
  • func (i *Impl) SetEventHandler(handler proto.ClientMessageHandler)
  • func (i *Impl) SetGroup(id int64)
• type Invocation
• type Result
• type Service
  • func NewService(handler Handler, eventDispatcher *event.DispatchService, ...) *Service
  • func (s *Service) Remove(correlationID int64) error
  • func (s *Service) SendRequest(ctx context.Context, inv Invocation) error
  • func (s *Service) SendUrgentRequest(ctx context.Context, inv Invocation) error
  • func (s *Service) SetHandler(handler Handler)
  • func (s *Service) Stop()
  • func (s *Service) WriteResponse(msg *proto.ClientMessage) error

Constants

const (
	// EventGroupLost is dispatched if an invocation group is lost, e.g., a connection closed
	EventGroupLost = "internal.invocation.grouplost"
)

Variables

var ErrResponseChannelClosed = errors.New("response channel closed")

Types

type GroupLostEvent

type GroupLostEvent struct {
	Err     error
	GroupID int64
}

func NewGroupLost

func NewGroupLost(groupID int64, err error) *GroupLostEvent

func (*GroupLostEvent) EventName

func (e *GroupLostEvent) EventName() string

type Handler

type Handler interface {
	Invoke(invocation Invocation) (groupID int64, err error)
}

type Impl

type Impl struct {
	RedoOperation bool
	// contains filtered or unexported fields
}

func NewImpl

func NewImpl(clientMessage *proto.ClientMessage, partitionID int32, address pubcluster.Address, deadline time.Time, redoOperation bool) *Impl

func (*Impl) Address

func (i *Impl) Address() pubcluster.Address

func (*Impl) CanRetry

func (i *Impl) CanRetry(err error) bool

func (*Impl) Close

func (i *Impl) Close()

func (*Impl) Complete

func (i *Impl) Complete(message *proto.ClientMessage)

func (*Impl) Completed

func (i *Impl) Completed() bool

func (*Impl) Deadline

func (i *Impl) Deadline() time.Time

func (*Impl) EventHandler

func (i *Impl) EventHandler() proto.ClientMessageHandler

func (*Impl) Get

func (i *Impl) Get() (*proto.ClientMessage, error)

func (*Impl) GetWithContext

func (i *Impl) GetWithContext(ctx context.Context) (*proto.ClientMessage, error)

func (*Impl) Group

func (i *Impl) Group() int64

func (*Impl) MaybeCanRetry

func (i *Impl) MaybeCanRetry(err error) bool

func (*Impl) PartitionID

func (i *Impl) PartitionID() int32

func (*Impl) Request

func (i *Impl) Request() *proto.ClientMessage

func (*Impl) SetEventHandler

func (i *Impl) SetEventHandler(handler proto.ClientMessageHandler)

SetEventHandler sets the event handler for the invocation. It should only be called at the site of creation.

func (*Impl) SetGroup

func (i *Impl) SetGroup(id int64)

type Invocation

type Invocation interface {
	Complete(message *proto.ClientMessage)
	Completed() bool
	EventHandler() proto.ClientMessageHandler
	Get() (*proto.ClientMessage, error)
	GetWithContext(ctx context.Context) (*proto.ClientMessage, error)
	PartitionID() int32
	Request() *proto.ClientMessage
	Address() pubcluster.Address
	Close()
	CanRetry(err error) bool
	Deadline() time.Time
	Group() int64
	SetGroup(id int64)
}

type Result

type Result interface {
	Get() (*proto.ClientMessage, error)
	GetWithTimeout(duration time.Duration) (*proto.ClientMessage, error)
}

type Service

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

func NewService

func NewService(
	handler Handler,
	eventDispatcher *event.DispatchService,
	logger logger.LogAdaptor) *Service

func (*Service) Remove

func (s *Service) Remove(correlationID int64) error

func (*Service) SendRequest

func (s *Service) SendRequest(ctx context.Context, inv Invocation) error

func (*Service) SendUrgentRequest

func (s *Service) SendUrgentRequest(ctx context.Context, inv Invocation) error

func (*Service) SetHandler

func (s *Service) SetHandler(handler Handler)

func (*Service) Stop

func (s *Service) Stop()

func (*Service) WriteResponse

func (s *Service) WriteResponse(msg *proto.ClientMessage) error