Documentation
¶
Index ¶
- Constants
- func ChannelToStr(ch *common.BasicChannel) string
- func LogRequest(handler func(http.ResponseWriter, *http.Request)) http.HandlerFunc
- func ServeNds3(listener net.Listener, db func() *mds.MetaDataStore, localReaderAddr string)
- type BufferedWriter
- type ChannelPredicateFull
- type ChannelPredicateSimple
- type Client
- type Epoch
- type StatusCapture
Constants ¶
View Source
const ( DAQD_OK = "0000" DAQD_ERR = "0001" DAQD_SYNTAX = "0019" DAQD_DELAY = "001c" )
Variables ¶
This section is empty.
Functions ¶
func ChannelToStr ¶
func ChannelToStr(ch *common.BasicChannel) string
func LogRequest ¶
func LogRequest(handler func(http.ResponseWriter, *http.Request)) http.HandlerFunc
Types ¶
type BufferedWriter ¶
BufferedWriter is an io.Writer that can be flushed. This allows the client to batch up writes and be more efficient.
type ChannelPredicateFull ¶
type ChannelPredicateFull struct {
ChannelPredicateSimple
// contains filtered or unexported fields
}
func CreateChannelPredicateFull ¶
func CreateChannelPredicateFull(pattern *nds2parser.BashPattern, classType common.ClassType) *ChannelPredicateFull
func (*ChannelPredicateFull) Matches ¶
func (p *ChannelPredicateFull) Matches(channel *mds.BasicChannel) bool
type ChannelPredicateSimple ¶
type ChannelPredicateSimple struct {
// contains filtered or unexported fields
}
func CreateChannelPredicateSimple ¶
func CreateChannelPredicateSimple(classType common.ClassType) *ChannelPredicateSimple
func (*ChannelPredicateSimple) Matches ¶
func (p *ChannelPredicateSimple) Matches(channel *mds.BasicChannel) bool
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func CreateClient ¶
func CreateClient(conn BufferedWriter, db *mds.MetaDataStore, epochs Epoch) *Client
func (*Client) Process ¶
func (c *Client) Process(command *nds2parser.ParsedCommand) error
type StatusCapture ¶
type StatusCapture struct {
// contains filtered or unexported fields
}
func NewStatusCapture ¶
func NewStatusCapture(w http.ResponseWriter) StatusCapture
func (*StatusCapture) Header ¶
func (l *StatusCapture) Header() http.Header
func (*StatusCapture) StatusCode ¶
func (l *StatusCapture) StatusCode() int
func (*StatusCapture) WriteHeader ¶
func (l *StatusCapture) WriteHeader(statusCode int)
Source Files
Click to show internal directories.
Click to hide internal directories.