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 []rpcModel.SshAccountMsg) []*proto.SshAccount
• func UnaryLogger() grpc.UnaryServerInterceptor
• func UnaryTokenAuth(key string) grpc.UnaryServerInterceptor
• 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 []rpcModel.SshAccountMsg) []*proto.SshAccount

func UnaryLogger

func UnaryLogger() grpc.UnaryServerInterceptor

func UnaryTokenAuth

func UnaryTokenAuth(key string) grpc.UnaryServerInterceptor

Types

type SshAccounts

type SshAccounts struct {
	proto.UnimplementedSshAccountsServer
}

func (*SshAccounts) Watch

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