stream

Apr 2, 2021 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Feb 2, 2021 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Jan 5, 2021 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Dec 1, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Nov 3, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Sep 30, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Sep 2, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Aug 5, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Jul 1, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Jun 1, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Apr 28, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Apr 3, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Changes in this version

+ type StreamDirection int

+ const ClientStream

+ const ServerStream

Feb 28, 2020 GO-2023-1582

  GO-2023-1582: Privilege escalation in MOSN in mosn.io/mosn

Changes in this version

+ var EAGAIN = errors.New("AGAIN")

+ var FAILED = errors.New("FAILED")

+ func CreateServerStreamConnection(context context.Context, prot types.Protocol, connection api.Connection, ...) types.ServerStreamConnection

+ func Register(prot types.Protocol, factory ProtocolStreamFactory)

+ func SelectStreamFactoryProtocol(ctx context.Context, prot string, peek []byte) (types.Protocol, error)

+ type BaseStream struct

+ func (s *BaseStream) AddEventListener(streamCb types.StreamEventListener)

+ func (s *BaseStream) DestroyStream()

+ func (s *BaseStream) RemoveEventListener(streamCb types.StreamEventListener)

+ func (s *BaseStream) ResetStream(reason types.StreamResetReason)

+ type Client interface

+ ActiveRequestsNum func() int

+ AddConnectionEventListener func(listener api.ConnectionEventListener)

+ Close func()

+ ConnID func() uint64

+ Connect func() error

+ NewStream func(context context.Context, respDecoder types.StreamReceiveListener) types.StreamSender

+ SetConnectionCollector func(read, write metrics.Counter)

+ SetStreamConnectionEventListener func(listener types.StreamConnectionEventListener)

+ func NewBiDirectStreamClient(ctx context.Context, prot types.Protocol, connection types.ClientConnection, ...) Client

+ func NewStreamClient(ctx context.Context, prot types.Protocol, connection types.ClientConnection, ...) Client

+ type ContextManager struct

+ func NewContextManager(base context.Context) *ContextManager

+ func (cm *ContextManager) Get() context.Context

+ func (cm *ContextManager) InjectTrace(ctx context.Context, span types.Span) context.Context

+ func (cm *ContextManager) Next()

+ type ProtocolStreamFactory interface

+ CreateBiDirectStream func(context context.Context, connection types.ClientConnection, ...) types.ClientStreamConnection

+ CreateClientStream func(context context.Context, connection types.ClientConnection, ...) types.ClientStreamConnection

+ CreateServerStream func(context context.Context, connection api.Connection, ...) types.ServerStreamConnection

+ ProtocolMatch func(context context.Context, prot string, magic []byte) error