backend

Documentation

Index

• type Socket
  • func (s *Socket) Disconnect()
  • func (s *Socket) End() error
  • func (s *Socket) Write(chunk []byte)
• type StreamBackend
  • func NewSocketBackend(endpoint string) StreamBackend

Types

type Socket

type Socket struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Socket) Disconnect

func (s *Socket) Disconnect()

func (*Socket) End

func (s *Socket) End() error

func (*Socket) Write

func (s *Socket) Write(chunk []byte)

type StreamBackend

type StreamBackend interface {
	Disconnect()
	Write([]byte)
	End() error
}

func NewSocketBackend

func NewSocketBackend(endpoint string) StreamBackend