kmipserver

Documentation

Index

• Variables
• func ClearIdPlaceholder(ctx context.Context)
• func Errorf(reason kmip.ResultReason, format string, args ...any) error
• func GetIdOrPlaceholder(ctx context.Context, reqId *string) (string, error)
• func GetProtocolVersion(ctx context.Context) kmip.ProtocolVersion
• func IdPlaceholder(ctx context.Context) *string
• func NewHTTPHandler(hdl RequestHandler) http.Handler
• func PeerCertificates(ctx context.Context) []*x509.Certificate
• func RemoteAddr(ctx context.Context) string
• func SetIdPlaceholder(ctx context.Context, id string)
• type BatchExecutor
  • func NewBatchExecutor() *BatchExecutor
  • func (exec *BatchExecutor) HandleRequest(ctx context.Context, req *kmip.RequestMessage) *kmip.ResponseMessage
  • func (exec *BatchExecutor) Route(op kmip.Operation, hdl OperationHandler)
  • func (exec *BatchExecutor) SetSupportedProtocolVersions(versions ...kmip.ProtocolVersion)
  • func (exec *BatchExecutor) Use(m ...Middleware)
• type Error
  • func (e Error) Error() string
• type Middleware
  • func DebugMiddleware(out io.Writer, marshal func(data any) []byte) Middleware
• type Next
• type OperationHandler
  • func HandleFunc[Req, Resp kmip.OperationPayload](h func(ctx context.Context, req Req) (Resp, error)) OperationHandler
• type RequestHandler
• type Server
  • func NewServer(listener net.Listener, handler RequestHandler) *Server
  • func (srv *Server) Serve() error
  • func (srv *Server) Shutdown() error

Variables

var (
	ErrOperationNotSupported = Errorf(kmip.ReasonOperationNotSupported, "Operation not supported")
	ErrFeatureNotSupported   = Errorf(kmip.ReasonFeatureNotSupported, "Feature not supported")
	ErrMissingData           = Errorf(kmip.ReasonMissingData, "Missing data")
	ErrItemNotFound          = Errorf(kmip.ReasonItemNotFound, "Item not found")
	ErrPermissionDenied      = Errorf(kmip.ReasonPermissionDenied, "Permission denied")
	ErrInvalidMessage        = Errorf(kmip.ReasonInvalidMessage, "Invalid message")
)

var ErrShutdown = errors.New("Server is shutting down")

Functions

func ClearIdPlaceholder

func ClearIdPlaceholder(ctx context.Context)

func Errorf

func Errorf(reason kmip.ResultReason, format string, args ...any) error

func GetIdOrPlaceholder

func GetIdOrPlaceholder(ctx context.Context, reqId *string) (string, error)

func GetProtocolVersion

func GetProtocolVersion(ctx context.Context) kmip.ProtocolVersion

func IdPlaceholder

func IdPlaceholder(ctx context.Context) *string

func NewHTTPHandler

func NewHTTPHandler(hdl RequestHandler) http.Handler

func PeerCertificates

func PeerCertificates(ctx context.Context) []*x509.Certificate

func RemoteAddr

func RemoteAddr(ctx context.Context) string

func SetIdPlaceholder

func SetIdPlaceholder(ctx context.Context, id string)

Types

type BatchExecutor

type BatchExecutor struct {
	// contains filtered or unexported fields
}

func NewBatchExecutor

func NewBatchExecutor() *BatchExecutor

func (*BatchExecutor) HandleRequest

func (exec *BatchExecutor) HandleRequest(ctx context.Context, req *kmip.RequestMessage) *kmip.ResponseMessage

func (*BatchExecutor) Route

func (exec *BatchExecutor) Route(op kmip.Operation, hdl OperationHandler)

func (*BatchExecutor) SetSupportedProtocolVersions

func (exec *BatchExecutor) SetSupportedProtocolVersions(versions ...kmip.ProtocolVersion)

func (*BatchExecutor) Use

func (exec *BatchExecutor) Use(m ...Middleware)

type Error

type Error struct {
	Reason  kmip.ResultReason
	Message string
}

func (Error) Error

func (e Error) Error() string

type Middleware

type Middleware func(next Next, ctx context.Context, msg *kmip.RequestMessage) (*kmip.ResponseMessage, error)

func DebugMiddleware

func DebugMiddleware(out io.Writer, marshal func(data any) []byte) Middleware

type Next

type Next func(context.Context, *kmip.RequestMessage) (*kmip.ResponseMessage, error)

type OperationHandler

type OperationHandler interface {
	HandleOperation(ctx context.Context, req kmip.OperationPayload) (kmip.OperationPayload, error)
}

func HandleFunc

func HandleFunc[Req, Resp kmip.OperationPayload](h func(ctx context.Context, req Req) (Resp, error)) OperationHandler

type RequestHandler

type RequestHandler interface {
	HandleRequest(ctx context.Context, req *kmip.RequestMessage) *kmip.ResponseMessage
}

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(listener net.Listener, handler RequestHandler) *Server

func (*Server) Serve

func (srv *Server) Serve() error

func (*Server) Shutdown

func (srv *Server) Shutdown() error