message

package
v0.0.0-...-17853a9 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Message 

type Message struct {
	Proto                *cppb.Message
	HttpRequest          *http.Request
	IsOpening            bool
	ResponseStatusHeader int
	ResponseHeaders      http.Header
	ResponseCookies      []*http.Cookie
}

func NewFromProto 

func NewFromProto(p *cppb.Message, req *http.Request) *Message

NOTE: It should be ok to pass nil as req pointer

func (*Message) AddResponseCookie 

func (m *Message) AddResponseCookie(cookie *http.Cookie)

func (*Message) BodyBytes 

func (m *Message) BodyBytes() MessageBody

func (*Message) ChannelId 

func (m *Message) ChannelId() string

func (*Message) DeserializeProtoBody 

func (m *Message) DeserializeProtoBody(dst protobuf.Message) error

func (*Message) ErrorMessage 

func (m *Message) ErrorMessage() string

func (*Message) ErrorMessages 

func (m *Message) ErrorMessages() []string

func (*Message) Errors 

func (m *Message) Errors() []error

func (*Message) FirstErrorMessage 

func (m *Message) FirstErrorMessage() string

func (*Message) IsEmpty 

func (m *Message) IsEmpty() bool

func (*Message) IsError 

func (m *Message) IsError() bool

func (*Message) IsFinalized 

func (m *Message) IsFinalized() bool

func (*Message) IsNotReady 

func (m *Message) IsNotReady() bool

func (*Message) IsPoll 

func (m *Message) IsPoll() bool

func (*Message) IsTerminated 

func (m *Message) IsTerminated() bool

func (*Message) LastDatumId 

func (m *Message) LastDatumId() string

func (*Message) LogFields 

func (m *Message) LogFields() logrus.Fields

func (*Message) NextDatumId 

func (m *Message) NextDatumId() string

func (*Message) PollDelay 

func (m *Message) PollDelay() time.Duration

func (*Message) PollDelayMs 

func (m *Message) PollDelayMs() int64

func (*Message) RequestCookie 

func (m *Message) RequestCookie(name string) *http.Cookie

func (*Message) RequestHeaders 

func (m *Message) RequestHeaders() (http.Header, bool)

func (*Message) RouteName 

func (m *Message) RouteName() string

func (*Message) Serialize 

func (m *Message) Serialize(asJSON bool) ([]byte, error)

func (*Message) SetAsOpening 

func (m *Message) SetAsOpening(isOpening bool) *Message

func (*Message) SetChannelId 

func (m *Message) SetChannelId(cid string) string

func (*Message) SetFallbackTraceId 

func (m *Message) SetFallbackTraceId(tid string) string

func (*Message) SetStatusHeader 

func (m *Message) SetStatusHeader(code int)

func (*Message) SetTraceId 

func (m *Message) SetTraceId(tid string) string

func (*Message) TraceId 

func (m *Message) TraceId() string

type MessageBody 

type MessageBody []byte

type MessageBuilder 

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

func Builder 

func Builder() MessageBuilder

func (MessageBuilder) Build 

func (b MessageBuilder) Build() (*Message, error)

func (MessageBuilder) Errors 

func (b MessageBuilder) Errors() []*cppb.Error

func (MessageBuilder) IsPoll 

func (b MessageBuilder) IsPoll() bool

func (MessageBuilder) IsTerminated 

func (b MessageBuilder) IsTerminated() bool

func (MessageBuilder) StatusCode 

func (b MessageBuilder) StatusCode() *int

func (MessageBuilder) WithBodyBytes 

func (b MessageBuilder) WithBodyBytes(bb []byte) MessageBuilder

func (MessageBuilder) WithChannelId 

func (b MessageBuilder) WithChannelId(cid string) MessageBuilder

func (MessageBuilder) WithEmpty 

func (b MessageBuilder) WithEmpty(isEmpty bool) MessageBuilder

func (MessageBuilder) WithError 

func (b MessageBuilder) WithError(err error) MessageBuilder

func (MessageBuilder) WithHTTPRequest 

func (b MessageBuilder) WithHTTPRequest(req *http.Request) MessageBuilder

func (MessageBuilder) WithLastDatumId 

func (b MessageBuilder) WithLastDatumId(did string) MessageBuilder

func (MessageBuilder) WithNextDatumId 

func (b MessageBuilder) WithNextDatumId(did string) MessageBuilder

func (MessageBuilder) WithNotReady 

func (b MessageBuilder) WithNotReady(nr bool) MessageBuilder

func (MessageBuilder) WithPollDelay 

func (b MessageBuilder) WithPollDelay(d time.Duration) MessageBuilder

func (MessageBuilder) WithResponseCookie 

func (b MessageBuilder) WithResponseCookie(cookie *http.Cookie) MessageBuilder

func (MessageBuilder) WithResponseCookies 

func (b MessageBuilder) WithResponseCookies(cookies []*http.Cookie) MessageBuilder

func (MessageBuilder) WithRouteName 

func (b MessageBuilder) WithRouteName(r string) MessageBuilder

func (MessageBuilder) WithStatusCode 

func (b MessageBuilder) WithStatusCode(code int) MessageBuilder

func (MessageBuilder) WithStatusCodePtr 

func (b MessageBuilder) WithStatusCodePtr(code *int) MessageBuilder

func (MessageBuilder) WithTerminated 

func (b MessageBuilder) WithTerminated(t bool) MessageBuilder

func (MessageBuilder) WithTraceId 

func (b MessageBuilder) WithTraceId(tid string) MessageBuilder

type Messages 

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

func NewMessages 

func NewMessages(parentMx *sync.RWMutex) *Messages

func (*Messages) DequeueIncoming 

func (m *Messages) DequeueIncoming(ctx context.Context) (*Message, error)

func (*Messages) DequeueIncomingNonblock 

func (m *Messages) DequeueIncomingNonblock() *Message

func (*Messages) DequeueIncomingTimeout 

func (m *Messages) DequeueIncomingTimeout(
	parent context.Context,
	timeout time.Duration,
) (*Message, error)

func (*Messages) DequeueOutgoing 

func (m *Messages) DequeueOutgoing(ctx context.Context) (*MessageBuilder, error)

func (*Messages) DequeueOutgoingNonblock 

func (m *Messages) DequeueOutgoingNonblock() *MessageBuilder

func (*Messages) DequeueOutgoingTimeout 

func (m *Messages) DequeueOutgoingTimeout(
	parent context.Context,
	timeout time.Duration,
) (
	*MessageBuilder, error,
)

func (*Messages) EnqueueIncoming 

func (m *Messages) EnqueueIncoming(ctx context.Context, msg *Message) error

func (*Messages) EnqueueIncomingNonblock 

func (m *Messages) EnqueueIncomingNonblock(msg *Message)

func (*Messages) EnqueueIncomingTimeout 

func (m *Messages) EnqueueIncomingTimeout(
	parent context.Context,
	msg *Message,
	timeout time.Duration,
) error

func (*Messages) EnqueueOutgoing 

func (m *Messages) EnqueueOutgoing(
	ctx context.Context,
	msgb MessageBuilder,
) error

func (*Messages) EnqueueOutgoingNonblock 

func (m *Messages) EnqueueOutgoingNonblock(msgb MessageBuilder)

func (*Messages) EnqueueOutgoingTimeout 

func (m *Messages) EnqueueOutgoingTimeout(
	msgb MessageBuilder,
	timeout time.Duration,
) error

func (*Messages) Incomings 

func (m *Messages) Incomings(ctx context.Context) <-chan *Message

func (*Messages) IncomingsSize 

func (m *Messages) IncomingsSize() int

func (*Messages) OutgoingsSize 

func (m *Messages) OutgoingsSize() int

func (*Messages) PeekIncoming 

func (m *Messages) PeekIncoming() *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.