dancer

package

v0.1.7 Latest Latest Go to latest Published: Jan 3, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/HnH/choreographer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Callback
type Dancer
- func New(sub message.Subscriber) (d Dancer)
type Message
- func NewMessage() *Message
- func NewMessageRaw(raw *message.Message) *Message
type Saga
- func (self *Saga) At(stepId string) *Step
type Step
- func (self *Step) Do(cb Callback) *Step
- func (self *Step) Undo(cb Callback) *Step

Constants ¶

View Source

const (
	HeaderContentType   = "content-type"
	HeaderSagaId        = "x-choreographer-saga-id"
	HeaderStepId        = "x-choreographer-step-id"
	HeaderEvent         = "x-choreographer-event"
	HeaderTimeSpent     = "x-choreographer-time-spent"
	HeaderAppendPayload = "x-choreographer-append-payload"
	HeaderAppendHeaders = "x-choreographer-append-headers"
	HeaderAppendTracing = "x-choreographer-append-tracing"

	ContentTypeJson     = "application/json"
	ContentTypeProtobuf = "application/protobuf"

	SagaStartedEvent   = "ChoreographerSagaStarted"
	SagaSucceededEvent = "ChoreographerSagaSucceeded"
	SagaFailedEvent    = "ChoreographerSagaFailed"
	SagaFinishedEvent  = "ChoreographerSagaFinished"
	StepStartedEvent   = "ChoreographerStepStarted"
	StepSucceededEvent = "ChoreographerStepSucceeded"
	StepFailedEvent    = "ChoreographerStepFailed"
	StepRollbackEvent  = "ChoreographerStepRollback"
	StepFinishedEvent  = "ChoreographerStepFinished"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Callback ¶ added in v0.1.2

type Callback func(*Message)

type Dancer ¶ added in v0.1.2

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

func New ¶ added in v0.1.2

func New(sub message.Subscriber) (d Dancer)

func (*Dancer) Listen ¶ added in v0.1.2

func (self *Dancer) Listen() (err error)

func (*Dancer) Saga ¶ added in v0.1.2

func (self *Dancer) Saga(sagaTopic string) *Saga

func (*Dancer) Stop ¶ added in v0.1.2

func (self *Dancer) Stop()

type Message ¶

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

func NewMessage ¶

func NewMessage() *Message

func NewMessageRaw ¶ added in v0.1.2

func NewMessageRaw(raw *message.Message) *Message

func (*Message) Ack ¶ added in v0.1.2

func (msg *Message) Ack() bool

func (*Message) Copy ¶ added in v0.1.2

func (msg *Message) Copy() *Message

func (*Message) EnsureHeadersProvided ¶ added in v0.1.2

func (msg *Message) EnsureHeadersProvided(keys ...string) error

func (*Message) GetAppendHeaders ¶ added in v0.1.7

func (msg *Message) GetAppendHeaders() string

func (*Message) GetAppendHeadersList ¶ added in v0.1.7

func (msg *Message) GetAppendHeadersList() []string

func (*Message) GetAppendPayload ¶ added in v0.1.7

func (msg *Message) GetAppendPayload() string

func (*Message) GetAppendPayloadMapping ¶ added in v0.1.7

func (msg *Message) GetAppendPayloadMapping() map[string]string

GetAppendPayloadMapping returns calculated append payload field mapping in form map[from field]to field

func (*Message) GetContext ¶ added in v0.1.2

func (msg *Message) GetContext() context.Context

func (*Message) GetEvent ¶

func (msg *Message) GetEvent() string

func (*Message) GetHeader ¶

func (msg *Message) GetHeader(key string) string

func (*Message) GetHeaders ¶ added in v0.1.2

func (msg *Message) GetHeaders() message.Metadata

func (*Message) GetPayload ¶

func (msg *Message) GetPayload() []byte

func (*Message) GetPayloadPath ¶ added in v0.1.2

func (msg *Message) GetPayloadPath(path string) json.RawMessage

func (*Message) GetSagaId ¶

func (msg *Message) GetSagaId() string

func (*Message) GetStepId ¶

func (msg *Message) GetStepId() string

func (*Message) Nack ¶ added in v0.1.7

func (msg *Message) Nack() bool

func (*Message) Raw ¶

func (msg *Message) Raw() *message.Message

func (*Message) SetAppendHeaders ¶ added in v0.1.7

func (msg *Message) SetAppendHeaders(h string) *Message

func (*Message) SetAppendPayload ¶ added in v0.1.7

func (msg *Message) SetAppendPayload(c map[string]string) *Message

func (*Message) SetAppendPayloadRaw ¶ added in v0.1.7

func (msg *Message) SetAppendPayloadRaw(c string) *Message

func (*Message) SetContext ¶ added in v0.1.2

func (msg *Message) SetContext(ctx context.Context) *Message

func (*Message) SetEvent ¶

func (msg *Message) SetEvent(e string) *Message

func (*Message) SetHeader ¶

func (msg *Message) SetHeader(key, value string) *Message

func (*Message) SetHeaders ¶ added in v0.1.7

func (msg *Message) SetHeaders(headers map[string]string) *Message

func (*Message) SetPayload ¶

func (msg *Message) SetPayload(p []byte) *Message

func (*Message) SetSagaId ¶

func (msg *Message) SetSagaId(id string) *Message

func (*Message) SetStepId ¶

func (msg *Message) SetStepId(id string) *Message

type Saga ¶ added in v0.1.2

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

func (*Saga) At ¶ added in v0.1.2

func (self *Saga) At(stepId string) *Step

type Step ¶ added in v0.1.2

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

func (*Step) Do ¶ added in v0.1.2

func (self *Step) Do(cb Callback) *Step

func (*Step) Undo ¶ added in v0.1.2

func (self *Step) Undo(cb Callback) *Step

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL