rpc

Documentation

Index

• func Run(token, addr string) error
• func StreamLogger() grpc.StreamServerInterceptor
• func StreamTokenAuth(key string) grpc.StreamServerInterceptor
• func TransformAccountArray(a []dto.SshDeploy) []*proto.SshAccount
• func TransformMsgArray(a []SshAccountMsg) []*proto.SshAccount
• func UnaryLogger() grpc.UnaryServerInterceptor
• func UnaryTokenAuth(key string) grpc.UnaryServerInterceptor
• type SshAccountMsg
  • func (a SshAccountMsg) Rpc() *proto.SshAccount
• type SshAccounts
  • func (a *SshAccounts) Watch(_ *emptypb.Empty, server proto.SshAccounts_WatchServer) error

Functions

func Run

func Run(token, addr string) error

func StreamLogger

func StreamLogger() grpc.StreamServerInterceptor

func StreamTokenAuth

func StreamTokenAuth(key string) grpc.StreamServerInterceptor

func TransformAccountArray

func TransformAccountArray(a []dto.SshDeploy) []*proto.SshAccount

func TransformMsgArray

func TransformMsgArray(a []SshAccountMsg) []*proto.SshAccount

func UnaryLogger

func UnaryLogger() grpc.UnaryServerInterceptor

func UnaryTokenAuth

func UnaryTokenAuth(key string) grpc.UnaryServerInterceptor

Types

type SshAccountMsg

type SshAccountMsg struct {
	IsDel     bool   `json:"isDel"`  // 是否为删除用户操作
	IsKill    bool   `json:"isKill"` // 是否为结束用户进程操作
	Username  string `json:"username"`
	PublicKey string `json:"publicKey"`
}

func (SshAccountMsg) Rpc

func (a SshAccountMsg) Rpc() *proto.SshAccount

type SshAccounts

type SshAccounts struct {
	proto.UnimplementedSshAccountsServer
}

func (*SshAccounts) Watch

func (a *SshAccounts) Watch(_ *emptypb.Empty, server proto.SshAccounts_WatchServer) error