options

Documentation

Index

• Constants
• func GetFilterFunc(filters []DeliverFilter) (func(message.ImmutableMessage) bool, error)
• func IsDeliverFilterTimeTick(filter DeliverFilter) bool
• type DeliverFilter
  • func DeliverFilterTimeTickGT(timeTick uint64) DeliverFilter
  • func DeliverFilterTimeTickGTE(timeTick uint64) DeliverFilter
  • func DeliverFilterVChannel(vchannel string) 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
	DeliverFilterTypeVChannel    deliverFilterType = 3
)

Functions

func GetFilterFunc

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

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 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.

func DeliverFilterVChannel

func DeliverFilterVChannel(vchannel string) DeliverFilter

DeliverFilterVChannel delivers messages filtered by vchannel.

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.