nkn

type Option ¶

type Option func(*Protocol) error

Option is the function signature required to be considered an pubsub.Option.

func WithConsumerAddress(address string) Option

func WithWalletSeed(seed string) Option

type Protocol ¶

type Protocol struct {
	// Sender
	SenderAccount string
	SenderClient  *nkn.Client

	// // Consumer
	ConsumerAddress string
}

func New(seed string, consumerAdress string, opts ...ProtocolOptionFunc) (*Protocol, error)

func NewProtocol(ctx context.Context, opts ...ProtocolOptionFunc) (*Protocol, error)

type ProtocolOptionFunc ¶

type ProtocolOptionFunc func(protocol *Protocol)

ProtocolOptionFunc is the type of kafka_sarama.Protocol options

type Sender ¶

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

func (s *Sender) Send(ctx context.Context, in binding.Message, transformers ...binding.Transformer) error

type SenderOptionFunc ¶

type SenderOptionFunc func(sender *Sender)