kafkasource

Documentation

Index

• func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ...) pkgadapter.Adapter
• func NewEnvConfig() adapter.EnvConfigAccessor
• type StaleList
  • func NewStaleList(timeout time.Duration) *StaleList
  • func (sl *StaleList) AddAndCount(object interface{}) int
  • func (sl *StaleList) Count() int
• type XDGSCRAMClient
  • func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
  • func (x *XDGSCRAMClient) Done() bool
  • func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Functions

func NewAdapter

func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ceClient cloudevents.Client) pkgadapter.Adapter

NewAdapter satisfies pkgadapter.AdapterConstructor. nolint:gocyclo

func NewEnvConfig

func NewEnvConfig() adapter.EnvConfigAccessor

NewEnvConfig satisfies pkgadapter.EnvConfigConstructor.

Types

type StaleList

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

StaleList is a list of items that timeout lazily, only checking for item expiration when a new one is added.

This should not be used for storing a big number of items.

func NewStaleList

func NewStaleList(timeout time.Duration) *StaleList

func (*StaleList) AddAndCount

func (sl *StaleList) AddAndCount(object interface{}) int

AddAndCount adds a new element to the list and updates the count, removing any stale items from it.

func (*StaleList) Count

func (sl *StaleList) Count() int

Count updates the count removing any stale items from it.

type XDGSCRAMClient

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

func (*XDGSCRAMClient) Begin

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

func (*XDGSCRAMClient) Done

func (x *XDGSCRAMClient) Done() bool

func (*XDGSCRAMClient) Step

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)