srpc

Aug 21, 2022

Changes in this version

type Session

+ func (s *Session) EndC() <-chan struct{}

type StreamHandle

+ func (h *StreamHandle) EndC() <-chan struct{}

Aug 20, 2022

Changes in this version

type StreamManager

+ func (m *StreamManager) SoftCancel(sid uint64, loaded *bool) error

Aug 20, 2022

Changes in this version

type StreamHandle

+ func (h *StreamHandle) SoftCancel() bool

Aug 12, 2022

Changes in this version

type SessionConfig

+ PollTimeout time.Duration

Aug 12, 2022

Changes in this version

+ type EndCause int

+ const EC_CLIENT_CANCELED

+ const EC_CLIENT_TIMEOUT

+ const EC_ERROR

+ const EC_NORMAL

+ const EC_PANIC

+ const EC_UNKNOWN

+ func (ec EndCause) Error() string

type Session

+ EndCause EndCause

+ func (s *Session) EndedC() <-chan struct{}

type StreamHandle

+ EndCause EndCause

+ func (h *StreamHandle) EndedC() <-chan struct{}

+ func (h *StreamHandle) IsEnded() bool

Aug 12, 2022

Changes in this version

type StreamHandle

+ func (h *StreamHandle) BlockUntilFinished()

+ func (h *StreamHandle) IsFinished() bool

Aug 12, 2022

Changes in this version

+ type StreamHandle struct

+ Err error

+ Panic *panicInfo

+ func (h *StreamHandle) C() <-chan any

+ func (h *StreamHandle) Cancel() bool

+ func (h *StreamHandle) CancelAndResult() error

+ func (h *StreamHandle) GetError() error

+ func (h *StreamHandle) Result() error

+ func (h *StreamHandle) Success() bool

Jun 4, 2022

Changes in this version

+ func S(f func() error, sess *Session, cfg *SessionConfig) error

+ func SetClientLogFunc(logf func(string))

+ func SetDefaultSessionConfig(cfg SessionConfig) bool

+ func SetServerLogFunc(logf func(string, ...any))

+ type Client struct

+ func WrapClient(c *rpc.Client) *Client

+ func (c *Client) CallStream(name string, args any) (h *streamHandle, err error)

+ type Session struct

+ Sid uint64

+ func (s *Session) Canceled() <-chan struct{}

+ func (s *Session) Logf(format string, args ...any)

+ func (s *Session) Logv(args ...any)

+ func (s *Session) PushValue(data any)

+ type SessionConfig struct

+ BufferCapacity int

+ ClientTimeout time.Duration

+ KeepAlive time.Duration

+ type SrpcError struct

+ ErrorString string

+ Typ string

+ func (s *SrpcError) Error() string

+ func (s *SrpcError) Format(f fmt.State, verb rune)

+ type StreamEvent struct

+ Data any

+ Typ streamEventType

+ type StreamManager struct

+ func (m *StreamManager) Cancel(sid uint64, reply *bool) error

+ func (m *StreamManager) Poll(sid uint64, reply *[]*StreamEvent) error