pktline

Documentation

Index

• Constants
• type ConnParams
• type Connection
• type ConnectionGroup
• type Connector
• type ConnectorManager
  • func NewConnectorManager(crlist []*ConnectorRegistration) ConnectorManager
• type ConnectorRegistration
• type ConnectorRegistry
• type Packet
• type Reader
• type ReaderCloser
  • func NewReaderCloser(r io.Reader, enableAutoClose bool) ReaderCloser
• type ReaderRaw
• type Writer
• type WriterCloser
  • func NewWriterCloser(w io.Writer, enableAutoClose bool) WriterCloser
• type WriterRaw

Constants

const (
	ServiceGitReceivePack = "git-receive-pack"
	ServiceGitUploadPack  = "git-upload-pack"
)

定义 git 服务名称

const (
	TypeGitUploadPackAdvertisement = "application/x-git-upload-pack-advertisement"
	TypeGitUploadPackRequest       = "application/x-git-upload-pack-request"
	TypeGitUploadPackResult        = "application/x-git-upload-pack-result"
	TypeGitReceivePackRequest      = "application/x-git-receive-pack-request"
	TypeGitReceivePackResult       = "application/x-git-receive-pack-result"
)

定义 git content-types

Types

type ConnParams

type ConnParams struct {
	Method       string
	URL          string
	Service      string
	ContentType  string // the request content-type
	SecurityOnly bool
}

ConnParams ...

type Connection

type Connection interface {
	io.Closer

	GetGroup() ConnectionGroup

	GetAttribute(name string) any

	SetAttribute(name string, value any)

	GetParams() *ConnParams

	GetService() string

	// @return (reader,contentType,error)
	OpenReader() (ReaderCloser, string, error)

	OpenWriter(contentType string) (WriterCloser, error)

	// 创建新的附加连接
	NewConnection(p *ConnParams) (Connection, error)
}

Connection ...

type ConnectionGroup

type ConnectionGroup interface {
	GetAttribute(name string) any

	SetAttribute(name string, value any)
}

ConnectionGroup ...

type Connector

type Connector interface {
	Connect(p *ConnParams) (Connection, error)

	Accept(p *ConnParams) bool
}

Connector ... [inject:".pktline-connector"]

type ConnectorManager

type ConnectorManager interface {
	Connector
}

ConnectorManager ... [inject:"#pktline-connector-manager"]

func NewConnectorManager

func NewConnectorManager(crlist []*ConnectorRegistration) ConnectorManager

NewConnectorManager 新建连接器管理器

type ConnectorRegistration

type ConnectorRegistration struct {
	Connector Connector
}

ConnectorRegistration ...

type ConnectorRegistry

type ConnectorRegistry interface {
	GetRegistration() *ConnectorRegistration
}

ConnectorRegistry 。。。[inject:".pktline-connector-registry"]

type Packet

type Packet struct {

	// * '0000' Flush Packet (flush-pkt) - indicates the end of a message
	// * '0001' Delimiter Packet (delim-pkt) - separates sections of a message
	// * '0002' Response End Packet (response-end-pkt) - indicates the end of a response for stateless connections
	Special bool

	Length int
	Head   string
	Body   []byte
}

Packet ...

type Reader

type Reader interface {
	Read() (*Packet, error)
}

Reader ...

type ReaderCloser

type ReaderCloser interface {
	Reader
	io.Closer
}

ReaderCloser ...

func NewReaderCloser

func NewReaderCloser(r io.Reader, enableAutoClose bool) ReaderCloser

NewReaderCloser ...

type ReaderRaw

type ReaderRaw interface {
	GetReader() io.Reader
}

ReaderRaw ...

type Writer

type Writer interface {
	Write(p *Packet) error
}

Writer ...

type WriterCloser

type WriterCloser interface {
	io.Closer
	Writer
}

WriterCloser ...

func NewWriterCloser

func NewWriterCloser(w io.Writer, enableAutoClose bool) WriterCloser

NewWriterCloser ...

type WriterRaw

type WriterRaw interface {
	GetWriter() io.Writer
}

WriterRaw ...