generator

Documentation

Index

• type MessageEncoding
  • func (me *MessageEncoding) Set(in string) error
  • func (me MessageEncoding) String() string
  • func (MessageEncoding) Type() string
• type Package
• type SubscriberGenerator
  • func NewSubscriberGenerator(pkgCfg *packages.Config, outW io.Writer) SubscriberGenerator
• type SubscriberParams
  • func (p *SubscriberParams) IsJSON() bool
  • func (p *SubscriberParams) IsProtobuf() bool
  • func (p *SubscriberParams) IsWithAdapter() bool
  • func (p *SubscriberParams) Validate() error

Types

type MessageEncoding

type MessageEncoding int

const (
	MessageEncodingUnknown MessageEncoding = iota
	MessageEncodingJSON
	MessageEncodingProtobuf
)

func (*MessageEncoding) Set

func (me *MessageEncoding) Set(in string) error

func (MessageEncoding) String

func (me MessageEncoding) String() string

func (MessageEncoding) Type

func (MessageEncoding) Type() string

type Package

type Package struct {
	Name string
	Path string
}

type SubscriberGenerator

type SubscriberGenerator interface {
	Generate(context.Context, *SubscriberParams) error
}

func NewSubscriberGenerator

func NewSubscriberGenerator(
	pkgCfg *packages.Config,
	outW io.Writer,
) SubscriberGenerator

type SubscriberParams

type SubscriberParams struct {
	Package  Package
	Message  string
	Encoding MessageEncoding
	Name     string
	Batch    bool
	Imports  []Package
}

func (*SubscriberParams) IsJSON

func (p *SubscriberParams) IsJSON() bool

func (*SubscriberParams) IsProtobuf

func (p *SubscriberParams) IsProtobuf() bool

func (*SubscriberParams) IsWithAdapter

func (p *SubscriberParams) IsWithAdapter() bool

func (*SubscriberParams) Validate

func (p *SubscriberParams) Validate() error