session

package

v0.14.1 Latest Latest Go to latest Published: Jul 7, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

View Source

const DefaultReceiveTimeout = 10 * time.Second

View Source

var ErrContextDone = errors.New("context done")

ErrContextDone is returned when the context is done.

View Source

var ErrNilMessage = errors.New("received message is nil")

ErrNilMessage is returned when a nil message is received.

View Source

var ErrTimeout = errors.New("session timeout")

ErrTimeout is returned when a session receive operation times out.

This section is empty.

type Marshaller interface {
	Marshal(v any) ([]byte, error)
	Unmarshal(data []byte, v any) error
}

Marshaller is a generic interface for marshalling and unmarshalling data.

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

func New(s Session, ctx context.Context, m Marshaller) *S

func (j *S) Info() view.SessionInfo

func (j *S) Receive(state any) error

func (j *S) ReceiveRaw() ([]byte, error)

func (j *S) ReceiveRawWithTimeout(d time.Duration) ([]byte, error)

func (j *S) ReceiveWithTimeout(state any, d time.Duration) error

func (j *S) Send(state any) error

func (j *S) SendError(err string) error

func (j *S) SendErrorWithContext(ctx context.Context, err string) error

func (j *S) SendRaw(ctx context.Context, raw []byte) error

func (j *S) SendWithContext(ctx context.Context, state any) error

func (j *S) Session() Session

type Session = view.Session

Path	Synopsis
mock Code generated by counterfeiter.	Code generated by counterfeiter.