rpcservice

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 27, 2020 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdminService 

type AdminService struct {
	Config *configv2.Config
	// contains filtered or unexported fields
}

func NewAdminService 

func NewAdminService(conf *configv2.Config, user database.UserDatabase) *AdminService

func (*AdminService) BackendList 

func (s *AdminService) BackendList(_ context.Context, req *rpc.RequestBackendList) (*rpc.ResponseBackendList, error)

func (*AdminService) BecomeMaintainer 

func (s *AdminService) BecomeMaintainer(ctx context.Context, req *rpc.RequestBecomeMaintainer) (*rpc.ResponseBecomeMaintainer, error)

func (*AdminService) Ping 

func (s *AdminService) Ping(_ context.Context, _ *rpc.RequestPing) (*rpc.ResponsePong, error)

func (*AdminService) RoleList 

func (s *AdminService) RoleList(ctx context.Context, _ *rpc.RequestRoleList) (*rpc.ResponseRoleList, error)

func (*AdminService) ToggleAdmin 

func (s *AdminService) ToggleAdmin(ctx context.Context, req *rpc.RequestToggleAdmin) (*rpc.ResponseToggleAdmin, error)

func (*AdminService) TokenNew 

func (s *AdminService) TokenNew(ctx context.Context, req *rpc.RequestTokenNew) (*rpc.ResponseTokenNew, error)

func (*AdminService) UserAdd 

func (s *AdminService) UserAdd(ctx context.Context, req *rpc.RequestUserAdd) (*rpc.ResponseUserAdd, error)

func (*AdminService) UserDel 

func (s *AdminService) UserDel(ctx context.Context, req *rpc.RequestUserDel) (*rpc.ResponseUserDel, error)

func (*AdminService) UserEdit added in v0.11.0 

func (s *AdminService) UserEdit(ctx context.Context, req *rpc.RequestUserEdit) (*rpc.ResponseUserEdit, error)

func (*AdminService) UserGet 

func (s *AdminService) UserGet(_ context.Context, req *rpc.RequestUserGet) (*rpc.ResponseUserGet, error)

func (*AdminService) UserList 

func (s *AdminService) UserList(ctx context.Context, req *rpc.RequestUserList) (*rpc.ResponseUserList, error)

type CertificateAuthorityService 

type CertificateAuthorityService struct {
	Config *configv2.Config
	// contains filtered or unexported fields
}

func NewCertificateAuthorityService 

func NewCertificateAuthorityService(conf *configv2.Config, ca *cert.CertificateAuthority) *CertificateAuthorityService

func (*CertificateAuthorityService) Get 

func (s *CertificateAuthorityService) Get(ctx context.Context, req *rpc.CARequestGet) (*rpc.CAResponseGet, error)

func (*CertificateAuthorityService) GetRevokedList 

func (s *CertificateAuthorityService) GetRevokedList(ctx context.Context, _ *rpc.RequestGetRevokedList) (*rpc.ResponseGetRevokedList, error)

func (*CertificateAuthorityService) GetSignedList 

func (s *CertificateAuthorityService) GetSignedList(ctx context.Context, _ *rpc.RequestGetSignedList) (*rpc.ResponseGetSignedList, error)

func (*CertificateAuthorityService) NewClientCert 

func (s *CertificateAuthorityService) NewClientCert(ctx context.Context, req *rpc.RequestNewClientCert) (*rpc.ResponseNewClientCert, error)

func (*CertificateAuthorityService) NewServerCert 

func (s *CertificateAuthorityService) NewServerCert(ctx context.Context, req *rpc.RequestNewServerCert) (*rpc.ResponseNewServerCert, error)

func (*CertificateAuthorityService) Revoke 

func (s *CertificateAuthorityService) Revoke(ctx context.Context, req *rpc.CARequestRevoke) (*rpc.CAResponseRevoke, error)

func (*CertificateAuthorityService) WatchRevokedCert 

func (s *CertificateAuthorityService) WatchRevokedCert(_ *rpc.RequestWatchRevokedCert, ss rpc.CertificateAuthority_WatchRevokedCertServer) error

type ClusterService 

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

func NewClusterService 

func NewClusterService(user database.UserDatabase, token database.TokenDatabase, cluster database.ClusterDatabase, relay database.RelayLocator) *ClusterService

func (*ClusterService) AgentList 

func (s *ClusterService) AgentList(_ context.Context, _ *rpc.RequestAgentList) (*rpc.ResponseAgentList, error)

func (*ClusterService) MemberList 

func (s *ClusterService) MemberList(ctx context.Context, _ *rpc.RequestMemberList) (*rpc.ResponseMemberList, error)

func (*ClusterService) MemberStat 

func (s *ClusterService) MemberStat(ctx context.Context, _ *rpc.RequestMemberStat) (*rpc.ResponseMemberStat, error)

type HealthService 

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

func NewHealthService 

func NewHealthService(isReady func() bool) *HealthService

func (*HealthService) Check 

func (h *HealthService) Check(_ context.Context, _ *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)

func (*HealthService) Watch 

func (h *HealthService) Watch(_ *healthpb.HealthCheckRequest, _ healthpb.Health_WatchServer) error

type UserService added in v0.8.0 

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

func NewUserService added in v0.8.0 

func NewUserService(user database.UserDatabase) *UserService

func (*UserService) GetGPGKey added in v0.9.0 

func (s *UserService) GetGPGKey(ctx context.Context, req *rpc.RequestGetGPGKey) (*rpc.ResponseGetGPGKey, error)

func (*UserService) GetSSHKey added in v0.8.0 

func (s *UserService) GetSSHKey(ctx context.Context, req *rpc.RequestGetSSHKey) (*rpc.ResponseGetSSHKey, error)

func (*UserService) SetGPGKey added in v0.9.0 

func (s *UserService) SetGPGKey(ctx context.Context, req *rpc.RequestSetGPGKey) (*rpc.ResponseSetGPGKey, error)

func (*UserService) SetSSHKey added in v0.8.0 

func (s *UserService) SetSSHKey(ctx context.Context, req *rpc.RequestSetSSHKey) (*rpc.ResponseSetSSHKey, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.