tests

package
v1.1.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 2, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Command1 

type Command1 struct {
	Data string
}

Command1 for testing

func (Command1) SchemaName 

func (Command1) SchemaName() string

SchemaName implementing gbus.Message

type Command2 

type Command2 struct {
	Data string
}

Command2 for testing

func (Command2) SchemaName 

func (Command2) SchemaName() string

SchemaName implementing gbus.Message

type Command3 added in v1.1.2 

type Command3 struct {
	Data string
}

Command3 for testing

func (Command3) SchemaName added in v1.1.2 

func (Command3) SchemaName() string

SchemaName implementing gbus.Message

type EmptyProtoCommand added in v1.1.2 

type EmptyProtoCommand struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmptyProtoCommand) Descriptor added in v1.1.2 

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

func (*EmptyProtoCommand) ProtoMessage added in v1.1.2 

func (*EmptyProtoCommand) ProtoMessage()

func (*EmptyProtoCommand) Reset added in v1.1.2 

func (m *EmptyProtoCommand) Reset()

func (*EmptyProtoCommand) SchemaName added in v1.1.2 

func (*EmptyProtoCommand) SchemaName() string

func (*EmptyProtoCommand) String added in v1.1.2 

func (m *EmptyProtoCommand) String() string

func (*EmptyProtoCommand) XXX_DiscardUnknown added in v1.1.2 

func (m *EmptyProtoCommand) XXX_DiscardUnknown()

func (*EmptyProtoCommand) XXX_Marshal added in v1.1.2 

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

func (*EmptyProtoCommand) XXX_Merge added in v1.1.2 

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

func (*EmptyProtoCommand) XXX_Size added in v1.1.2 

func (m *EmptyProtoCommand) XXX_Size() int

func (*EmptyProtoCommand) XXX_Unmarshal added in v1.1.2 

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

type Event1 

type Event1 struct {
	Data string
}

Event1 for testing

func (Event1) SchemaName 

func (Event1) SchemaName() string

SchemaName implementing gbus.Message

type Event2 

type Event2 struct {
	Data string
}

Event2 for testing

func (Event2) SchemaName 

func (Event2) SchemaName() string

SchemaName implementing gbus.Message

type PoisonMessage added in v1.1.0 

type PoisonMessage struct {
}

PoisonMessage is a malformed message to test poison pill scenarios

func (PoisonMessage) SchemaName added in v1.1.0 

func (PoisonMessage) SchemaName() string

SchemaName implementing gbus.Message

type ProtoCommand added in v1.0.2 

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 added in v1.0.2 

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

func (*ProtoCommand) GetSomeData added in v1.0.2 

func (m *ProtoCommand) GetSomeData() string

func (*ProtoCommand) GetSomeNumber added in v1.0.2 

func (m *ProtoCommand) GetSomeNumber() int64

func (*ProtoCommand) ProtoMessage added in v1.0.2 

func (*ProtoCommand) ProtoMessage()

func (*ProtoCommand) Reset added in v1.0.2 

func (m *ProtoCommand) Reset()

func (*ProtoCommand) SchemaName added in v1.0.2 

func (*ProtoCommand) SchemaName() string

SchemaName implements the gbus.Message contract for ProtoCommand

func (*ProtoCommand) String added in v1.0.2 

func (m *ProtoCommand) String() string

func (*ProtoCommand) XXX_DiscardUnknown added in v1.0.2 

func (m *ProtoCommand) XXX_DiscardUnknown()

func (*ProtoCommand) XXX_Marshal added in v1.0.2 

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

func (*ProtoCommand) XXX_Merge added in v1.0.2 

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

func (*ProtoCommand) XXX_Size added in v1.0.2 

func (m *ProtoCommand) XXX_Size() int

func (*ProtoCommand) XXX_Unmarshal added in v1.0.2 

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

type Reply1 

type Reply1 struct {
	Data string
}

Reply1 for testing

func (Reply1) SchemaName 

func (Reply1) SchemaName() string

SchemaName implementing gbus.Message

type Reply2 

type Reply2 struct {
	Data string
}

Reply2 for testing

func (Reply2) SchemaName 

func (Reply2) SchemaName() string

SchemaName implementing gbus.Message

type Reply3 added in v1.1.2 

type Reply3 struct {
	Data string
}

Reply3 for testing

func (Reply3) SchemaName added in v1.1.2 

func (Reply3) SchemaName() string

SchemaName implementing gbus.Message

type ReplyToCreatorSaga2 added in v1.1.2 

type ReplyToCreatorSaga2 struct {
}

func (*ReplyToCreatorSaga2) HandleCommand2 added in v1.1.2 

func (s *ReplyToCreatorSaga2) HandleCommand2(invocation gbus.Invocation, message *gbus.BusMessage) error

func (*ReplyToCreatorSaga2) HandleCommand3 added in v1.1.2 

func (s *ReplyToCreatorSaga2) HandleCommand3(invocation gbus.Invocation, message *gbus.BusMessage) error

func (*ReplyToCreatorSaga2) IsComplete added in v1.1.2 

func (s *ReplyToCreatorSaga2) IsComplete() bool

func (*ReplyToCreatorSaga2) New added in v1.1.2 

func (s *ReplyToCreatorSaga2) New() gbus.Saga

func (*ReplyToCreatorSaga2) RegisterAllHandlers added in v1.1.2 

func (s *ReplyToCreatorSaga2) RegisterAllHandlers(register gbus.HandlerRegister)

func (*ReplyToCreatorSaga2) StartedBy added in v1.1.2 

func (*ReplyToCreatorSaga2) StartedBy() []gbus.Message

type ReplyToInitiatorSaga1 added in v1.1.2 

type ReplyToInitiatorSaga1 struct {
	DelegateToSvc string
}

func (*ReplyToInitiatorSaga1) HandleCommand1 added in v1.1.2 

func (s *ReplyToInitiatorSaga1) HandleCommand1(invocation gbus.Invocation, message *gbus.BusMessage) error

func (*ReplyToInitiatorSaga1) HandleRepl2 added in v1.1.2 

func (s *ReplyToInitiatorSaga1) HandleRepl2(invocation gbus.Invocation, message *gbus.BusMessage) error

func (*ReplyToInitiatorSaga1) IsComplete added in v1.1.2 

func (s *ReplyToInitiatorSaga1) IsComplete() bool

func (*ReplyToInitiatorSaga1) New added in v1.1.2 

func (s *ReplyToInitiatorSaga1) New() gbus.Saga

func (*ReplyToInitiatorSaga1) RegisterAllHandlers added in v1.1.2 

func (s *ReplyToInitiatorSaga1) RegisterAllHandlers(register gbus.HandlerRegister)

func (*ReplyToInitiatorSaga1) StartedBy added in v1.1.2 

func (*ReplyToInitiatorSaga1) StartedBy() []gbus.Message

type ReplyToInitiatorSaga3 added in v1.1.3 

type ReplyToInitiatorSaga3 struct {
}

func (*ReplyToInitiatorSaga3) HandleCommand1 added in v1.1.3 

func (s *ReplyToInitiatorSaga3) HandleCommand1(invocation gbus.Invocation, message *gbus.BusMessage) error

func (*ReplyToInitiatorSaga3) HandleCommand2 added in v1.1.3 

func (s *ReplyToInitiatorSaga3) HandleCommand2(invocation gbus.Invocation, message *gbus.BusMessage) error

func (*ReplyToInitiatorSaga3) IsComplete added in v1.1.3 

func (s *ReplyToInitiatorSaga3) IsComplete() bool

func (*ReplyToInitiatorSaga3) New added in v1.1.3 

func (s *ReplyToInitiatorSaga3) New() gbus.Saga

func (*ReplyToInitiatorSaga3) RegisterAllHandlers added in v1.1.3 

func (s *ReplyToInitiatorSaga3) RegisterAllHandlers(register gbus.HandlerRegister)

func (*ReplyToInitiatorSaga3) StartedBy added in v1.1.3 

func (*ReplyToInitiatorSaga3) StartedBy() []gbus.Message

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.