api

Documentation

Index

• func NewSyncResourceTerminal(conn *websocket.Conn) secret.Rpc_SyncResourceServer
• type Handler
  • func (h *Handler) Init() error
  • func (h *Handler) Name() string
  • func (h *Handler) QuerySecret(r *restful.Request, w *restful.Response)
  • func (h *Handler) Registry(r *restful.WebService)
  • func (h *Handler) SyncResource(r *restful.Request, w *restful.Response)
• type SyncResourceTerminal
  • func (m *SyncResourceTerminal) Send(resp *secret.SyncResourceResponse) error

Functions

func NewSyncResourceTerminal

func NewSyncResourceTerminal(conn *websocket.Conn) secret.Rpc_SyncResourceServer

Types

type Handler

type Handler struct {
	// 需要一个业务的具体实现
	// svc token.Service
	// 托管Ioc
	ioc.IocObjectImpl
	// contains filtered or unexported fields
}

func (*Handler) Init

func (h *Handler) Init() error

让他从Ioc中获取依赖的对象

func (*Handler) Name

func (h *Handler) Name() string

func (*Handler) QuerySecret

func (h *Handler) QuerySecret(r *restful.Request, w *restful.Response)

GoRestful Handler 需要符合框架签名

func (*Handler) Registry

func (h *Handler) Registry(r *restful.WebService)

func (*Handler) SyncResource

func (h *Handler) SyncResource(r *restful.Request, w *restful.Response)

GoRestful Handler 需要符合框架签名

type SyncResourceTerminal

type SyncResourceTerminal struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

只是打印下需要发送的对象

func (*SyncResourceTerminal) Send

func (m *SyncResourceTerminal) Send(
	resp *secret.SyncResourceResponse) error