tests

Documentation

Index

• type Command1
  • func (Command1) SchemaName() string
• type Command2
  • func (Command2) SchemaName() string
• type Event1
  • func (Event1) SchemaName() string
• type Event2
  • func (Event2) SchemaName() string
• type PoisonMessage
  • func (PoisonMessage) SchemaName() string
• type ProtoCommand
  • func (*ProtoCommand) Descriptor() ([]byte, []int)
  • func (m *ProtoCommand) GetSomeData() string
  • func (m *ProtoCommand) GetSomeNumber() int64
  • func (*ProtoCommand) ProtoMessage()
  • func (m *ProtoCommand) Reset()
  • func (*ProtoCommand) SchemaName() string
  • func (m *ProtoCommand) String() string
  • func (m *ProtoCommand) XXX_DiscardUnknown()
  • func (m *ProtoCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ProtoCommand) XXX_Merge(src proto.Message)
  • func (m *ProtoCommand) XXX_Size() int
  • func (m *ProtoCommand) XXX_Unmarshal(b []byte) error
• type Reply1
  • func (Reply1) SchemaName() string
• type Reply2
  • func (Reply2) SchemaName() string

Types

type Command1

type Command1 struct {
	Data string
}

func (Command1) SchemaName

func (Command1) SchemaName() string

type Command2

type Command2 struct {
	Data string
}

func (Command2) SchemaName

func (Command2) SchemaName() string

type Event1

type Event1 struct {
	Data string
}

func (Event1) SchemaName

func (Event1) SchemaName() string

type Event2

type Event2 struct {
	Data string
}

func (Event2) SchemaName

func (Event2) SchemaName() string

type PoisonMessage

type PoisonMessage struct {
}

func (PoisonMessage) SchemaName

func (PoisonMessage) SchemaName() string

type ProtoCommand

type ProtoCommand struct {
	SomeNumber           int64    `protobuf:"varint,1,opt,name=some_number,json=someNumber,proto3" json:"some_number,omitempty"`
	SomeData             string   `protobuf:"bytes,2,opt,name=some_data,json=someData,proto3" json:"some_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProtoCommand) Descriptor

func (*ProtoCommand) Descriptor() ([]byte, []int)

func (*ProtoCommand) GetSomeData

func (m *ProtoCommand) GetSomeData() string

func (*ProtoCommand) GetSomeNumber

func (m *ProtoCommand) GetSomeNumber() int64

func (*ProtoCommand) ProtoMessage

func (*ProtoCommand) ProtoMessage()

func (*ProtoCommand) Reset

func (m *ProtoCommand) Reset()

func (*ProtoCommand) SchemaName

func (*ProtoCommand) SchemaName() string

func (*ProtoCommand) String

func (m *ProtoCommand) String() string

func (*ProtoCommand) XXX_DiscardUnknown

func (m *ProtoCommand) XXX_DiscardUnknown()

func (*ProtoCommand) XXX_Marshal

func (m *ProtoCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtoCommand) XXX_Merge

func (m *ProtoCommand) XXX_Merge(src proto.Message)

func (*ProtoCommand) XXX_Size

func (m *ProtoCommand) XXX_Size() int

func (*ProtoCommand) XXX_Unmarshal

func (m *ProtoCommand) XXX_Unmarshal(b []byte) error

type Reply1

type Reply1 struct {
	Data string
}

func (Reply1) SchemaName

func (Reply1) SchemaName() string

type Reply2

type Reply2 struct {
	Data string
}

func (Reply2) SchemaName

func (Reply2) SchemaName() string