160 lines
4.5 KiB
Go
160 lines
4.5 KiB
Go
package client
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
cmapi "certmanager/api/certmanagercontrol"
|
|
"certmanager/pkg/auxgrpc"
|
|
)
|
|
|
|
func (cont *Control) CreateIssuerPair(ctx context.Context, param *cmapi.CreateIssuerPairParams) (*cmapi.CreateIssuerPairResult, error) {
|
|
var err error
|
|
res := &cmapi.CreateIssuerPairResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.CreateIssuerPair(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|
|
|
|
func (cont *Control) ImportIssuerPair(ctx context.Context, param *cmapi.ImportIssuerPairParams) (*cmapi.ImportIssuerPairResult, error) {
|
|
var err error
|
|
res := &cmapi.ImportIssuerPairResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.ImportIssuerPair(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|
|
|
|
func (cont *Control) RevokeIssuerPair(ctx context.Context, param *cmapi.RevokeIssuerPairParams) (*cmapi.RevokeIssuerPairResult, error) {
|
|
var err error
|
|
res := &cmapi.RevokeIssuerPairResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.RevokeIssuerPair(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|
|
|
|
func (cont *Control) UnrevokeIssuerPair(ctx context.Context, param *cmapi.UnrevokeIssuerPairParams) (*cmapi.UnrevokeIssuerPairResult, error) {
|
|
var err error
|
|
res := &cmapi.UnrevokeIssuerPairResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.UnrevokeIssuerPair(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|
|
|
|
func (cont *Control) ListIssuerPairs(ctx context.Context, param *cmapi.ListIssuerPairsParams) (*cmapi.ListIssuerPairsResult, error) {
|
|
var err error
|
|
res := &cmapi.ListIssuerPairsResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.ListIssuerPairs(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|
|
|
|
func (cont *Control) GetIssuerCertificate(ctx context.Context, param *cmapi.GetIssuerCertificateParams) (*cmapi.GetIssuerCertificateResult, error) {
|
|
var err error
|
|
res := &cmapi.GetIssuerCertificateResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.GetIssuerCertificate(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|
|
|
|
func (cont *Control) CreateServicePair(ctx context.Context, param *cmapi.CreateServicePairParams) (*cmapi.CreateServicePairResult, error) {
|
|
var err error
|
|
res := &cmapi.CreateServicePairResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.CreateServicePair(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|
|
|
|
func (cont *Control) RevokeServicePair(ctx context.Context, param *cmapi.RevokeServicePairParams) (*cmapi.RevokeServicePairResult, error) {
|
|
var err error
|
|
res := &cmapi.RevokeServicePairResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.RevokeServicePair(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|
|
|
|
func (cont *Control) ListServicePairs(ctx context.Context, param *cmapi.ListServicePairsParams) (*cmapi.ListServicePairsResult, error) {
|
|
var err error
|
|
res := &cmapi.ListServicePairsResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.ListServicePairs(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|
|
|
|
func (cont *Control) GetServicePair(ctx context.Context, param *cmapi.GetServicePairParams) (*cmapi.GetServicePairResult, error) {
|
|
var err error
|
|
res := &cmapi.GetServicePairResult{}
|
|
|
|
const timeout time.Duration = 50 * time.Second
|
|
ctx, cancel := context.WithTimeout(ctx, timeout)
|
|
defer cancel()
|
|
res, err = cont.client.GetServicePair(ctx, param)
|
|
err = auxgrpc.FmtError(err)
|
|
if err != nil {
|
|
return res, err
|
|
}
|
|
return res, err
|
|
}
|