options

Documentation

Index

• Constants
• func GetFilterFunc(filters []DeliverFilter) func(message.ImmutableMessage) bool
• func IsDeliverFilterTimeTick(filter DeliverFilter) bool
• type DeliverFilter
  • func DeliverFilterMessageType(messageType ...message.MessageType) DeliverFilter
  • func DeliverFilterTimeTickGT(timeTick uint64) DeliverFilter
  • func DeliverFilterTimeTickGTE(timeTick uint64) DeliverFilter
• type DeliverPolicy
  • func DeliverPolicyAll() DeliverPolicy
  • func DeliverPolicyLatest() DeliverPolicy
  • func DeliverPolicyStartAfter(messageID message.MessageID) DeliverPolicy
  • func DeliverPolicyStartFrom(messageID message.MessageID) DeliverPolicy

Constants

const (
	DeliverPolicyTypeAll        deliverPolicyType = 1
	DeliverPolicyTypeLatest     deliverPolicyType = 2
	DeliverPolicyTypeStartFrom  deliverPolicyType = 3
	DeliverPolicyTypeStartAfter deliverPolicyType = 4

	DeliverFilterTypeTimeTickGT  deliverFilterType = 1
	DeliverFilterTypeTimeTickGTE deliverFilterType = 2
	DeliverFilterTypeMessageType deliverFilterType = 3
)

Functions

func GetFilterFunc

func GetFilterFunc(filters []DeliverFilter) func(message.ImmutableMessage) bool

GetFilterFunc returns the filter function.

func IsDeliverFilterTimeTick

func IsDeliverFilterTimeTick(filter DeliverFilter) bool

IsDeliverFilterTimeTick checks if the filter is time tick filter.

Types

type DeliverFilter

type DeliverFilter = *streamingpb.DeliverFilter

func DeliverFilterMessageType

func DeliverFilterMessageType(messageType ...message.MessageType) DeliverFilter

DeliverFilterMessageType delivers messages filtered by message type.

func DeliverFilterTimeTickGT

func DeliverFilterTimeTickGT(timeTick uint64) DeliverFilter

DeliverFilterTimeTickGT delivers messages by time tick greater than the specified time tick.

func DeliverFilterTimeTickGTE

func DeliverFilterTimeTickGTE(timeTick uint64) DeliverFilter

DeliverFilterTimeTickGTE delivers messages by time tick greater than or equal to the specified time tick.

type DeliverPolicy

type DeliverPolicy = *streamingpb.DeliverPolicy

func DeliverPolicyAll

func DeliverPolicyAll() DeliverPolicy

DeliverPolicyAll delivers all messages.

func DeliverPolicyLatest

func DeliverPolicyLatest() DeliverPolicy

DeliverLatest delivers the latest message.

func DeliverPolicyStartAfter

func DeliverPolicyStartAfter(messageID message.MessageID) DeliverPolicy

DeliverPolicyStartAfter delivers the message after the specified message.

func DeliverPolicyStartFrom

func DeliverPolicyStartFrom(messageID message.MessageID) DeliverPolicy

DeliverEarliest delivers the earliest message.