rpcservice

Documentation

Index

• type AdminService
  • func NewAdminService(conf *config.Config, user database.UserDatabase) *AdminService
  • func (s *AdminService) BackendList(_ context.Context, req *rpc.RequestBackendList) (*rpc.ResponseBackendList, error)
  • func (s *AdminService) BecomeMaintainer(ctx context.Context, req *rpc.RequestBecomeMaintainer) (*rpc.ResponseBecomeMaintainer, error)
  • func (s *AdminService) Ping(_ context.Context, _ *rpc.RequestPing) (*rpc.ResponsePong, error)
  • func (s *AdminService) RoleList(ctx context.Context, _ *rpc.RequestRoleList) (*rpc.ResponseRoleList, error)
  • func (s *AdminService) ToggleAdmin(ctx context.Context, req *rpc.RequestToggleAdmin) (*rpc.ResponseToggleAdmin, error)
  • func (s *AdminService) TokenNew(ctx context.Context, req *rpc.RequestTokenNew) (*rpc.ResponseTokenNew, error)
  • func (s *AdminService) UserAdd(ctx context.Context, req *rpc.RequestUserAdd) (*rpc.ResponseUserAdd, error)
  • func (s *AdminService) UserDel(ctx context.Context, req *rpc.RequestUserDel) (*rpc.ResponseUserDel, error)
  • func (s *AdminService) UserGet(_ context.Context, req *rpc.RequestUserGet) (*rpc.ResponseUserGet, error)
  • func (s *AdminService) UserList(ctx context.Context, req *rpc.RequestUserList) (*rpc.ResponseUserList, error)
• type CertificateAuthorityService
  • func NewCertificateAuthorityService(conf *config.Config, ca *cert.CertificateAuthority) *CertificateAuthorityService
  • func (s *CertificateAuthorityService) Get(ctx context.Context, req *rpc.CARequestGet) (*rpc.CAResponseGet, error)
  • func (s *CertificateAuthorityService) GetRevokedList(ctx context.Context, _ *rpc.RequestGetRevokedList) (*rpc.ResponseGetRevokedList, error)
  • func (s *CertificateAuthorityService) GetSignedList(ctx context.Context, _ *rpc.RequestGetSignedList) (*rpc.ResponseGetSignedList, error)
  • func (s *CertificateAuthorityService) NewClientCert(ctx context.Context, req *rpc.RequestNewClientCert) (*rpc.ResponseNewClientCert, error)
  • func (s *CertificateAuthorityService) NewServerCert(ctx context.Context, req *rpc.RequestNewServerCert) (*rpc.ResponseNewServerCert, error)
  • func (s *CertificateAuthorityService) Revoke(ctx context.Context, req *rpc.CARequestRevoke) (*rpc.CAResponseRevoke, error)
  • func (s *CertificateAuthorityService) WatchRevokedCert(_ *rpc.RequestWatchRevokedCert, ...) error
• type ClusterService
  • func NewClusterService(user database.UserDatabase, token database.TokenDatabase, ...) *ClusterService
  • func (s *ClusterService) AgentList(_ context.Context, _ *rpc.RequestAgentList) (*rpc.ResponseAgentList, error)
  • func (s *ClusterService) MemberList(ctx context.Context, _ *rpc.RequestMemberList) (*rpc.ResponseMemberList, error)
  • func (s *ClusterService) MemberStat(ctx context.Context, _ *rpc.RequestMemberStat) (*rpc.ResponseMemberStat, error)
• type HealthService
  • func NewHealthService(isReady func() bool) *HealthService
  • func (h *HealthService) Check(_ context.Context, _ *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
  • func (h *HealthService) Watch(_ *healthpb.HealthCheckRequest, _ healthpb.Health_WatchServer) error

Types

type AdminService

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

func NewAdminService

func NewAdminService(conf *config.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) 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 *config.Config
	// contains filtered or unexported fields
}

func NewCertificateAuthorityService

func NewCertificateAuthorityService(conf *config.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