request

Documentation

Index

• type Dialer
• type Listener
• type OptionSupportsStreamingResponse
• type OptionSupportsStreamingResponseExtensionFlusher
• type Request
• type Response
• type RoundTripperClient
• type RoundTripperOption
• type RoundTripperServer
• type Session
• type SessionAssemblerClient
• type SessionAssemblerServer
• type SessionCreator
• type SessionOption
• type SessionReceiver
• type TransportClientAssembly
• type TransportClientAssemblyReceiver
• type TransportServerAssembly
• type TransportServerAssemblyReceiver
• type Tripper
• type TripperReceiver

Types

type Dialer

type Dialer interface {
	Dial(ctx context.Context) (net.Conn, error)
}

type Listener

type Listener interface {
	Listen(ctx context.Context) (net.Listener, error)
}

type OptionSupportsStreamingResponse

type OptionSupportsStreamingResponse interface {
	RoundTripperOption
	GetResponseWriter() io.Writer
}

type OptionSupportsStreamingResponseExtensionFlusher

type OptionSupportsStreamingResponseExtensionFlusher interface {
	Flush()
}

type Request

type Request struct {
	Data          []byte
	ConnectionTag []byte
}

type Response

type Response struct {
	Data []byte
}

type RoundTripperClient

type RoundTripperClient interface {
	Tripper
	TransportClientAssemblyReceiver
}

type RoundTripperOption

type RoundTripperOption interface {
	RoundTripperOption()
}

type RoundTripperServer

type RoundTripperServer interface {
	common.Runnable
	TransportServerAssemblyReceiver
}

type Session

type Session interface {
	io.ReadWriteCloser
}

type SessionAssemblerClient

type SessionAssemblerClient interface {
	SessionCreator
	TransportClientAssemblyReceiver
}

type SessionAssemblerServer

type SessionAssemblerServer interface {
	TripperReceiver
	TransportServerAssemblyReceiver
}

type SessionCreator

type SessionCreator interface {
	NewSession(ctx context.Context, opts ...SessionOption) (Session, error)
}

type SessionOption

type SessionOption interface {
	RoundTripperOption()
}

type SessionReceiver

type SessionReceiver interface {
	OnNewSession(ctx context.Context, sess Session, opts ...SessionOption) error
}

type TransportClientAssembly

type TransportClientAssembly interface {
	Tripper() Tripper
	AutoImplDialer() Dialer
}

type TransportClientAssemblyReceiver

type TransportClientAssemblyReceiver interface {
	OnTransportClientAssemblyReady(TransportClientAssembly)
}

type TransportServerAssembly

type TransportServerAssembly interface {
	TripperReceiver() TripperReceiver
	SessionReceiver() SessionReceiver
	AutoImplListener() Listener
}

type TransportServerAssemblyReceiver

type TransportServerAssemblyReceiver interface {
	OnTransportServerAssemblyReady(TransportServerAssembly)
}

type Tripper

type Tripper interface {
	RoundTrip(ctx context.Context, req Request, opts ...RoundTripperOption) (resp Response, err error)
}

type TripperReceiver

type TripperReceiver interface {
	OnRoundTrip(ctx context.Context, req Request, opts ...RoundTripperOption) (resp Response, err error)
}