grpc

package
v0.0.17 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2026 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MapAuthDtoSDKToGRPC 

func MapAuthDtoSDKToGRPC(authData *dto.AuthAuditDTO) *pb.AuthAudit

func MapDataDtoSDKToGRPC 

func MapDataDtoSDKToGRPC(data *dto.DataAuditDTO) *pb.DataAudit

func MapDataValueDTOsSDKToGRPC 

func MapDataValueDTOsSDKToGRPC(dataValues []*dto.DataAuditValueDTO) []*pb.DataAuditValue

func MapDataValueDtoSDKToGRPC 

func MapDataValueDtoSDKToGRPC(dataValue *dto.DataAuditValueDTO) *pb.DataAuditValue

Types

type AuditClientConfig 

type AuditClientConfig struct {
	Target   string
	GRPCConf *RawGRPCClientConfig
	// contains filtered or unexported fields
}

func NewAuditAuditClientConfig 

func NewAuditAuditClientConfig(
	grpcConf *RawGRPCClientConfig,
	poolConf *worker.BasePoolConfig,
) *AuditClientConfig

type AuthAuditClient 

type AuthAuditClient struct {
	*BaseAuditClient[*dto.AuthAuditDTO]
	// contains filtered or unexported fields
}

func NewAuthAuditClient 

func NewAuthAuditClient(
	conf *AuditClientConfig,
	tokenProvider transportauth.TokenProvider,
	log logger.Logger,
) *AuthAuditClient

func (*AuthAuditClient) Start 

func (acc *AuthAuditClient) Start(ctx context.Context) error

func (*AuthAuditClient) Stop 

func (acc *AuthAuditClient) Stop(stopTimeout time.Duration) error

type BaseAuditClient 

type BaseAuditClient[D any] struct {
	*client.BaseAuditClient[D]
	// contains filtered or unexported fields
}

func NewBaseAuditClient 

func NewBaseAuditClient[D any](
	name string,
	conf *AuditClientConfig,
	tokenProvider transportauth.TokenProvider,
	auditAction client.AuditAction[D],
	log logger.Logger,
) *BaseAuditClient[D]

func (*BaseAuditClient[D]) GetConfig 

func (bac *BaseAuditClient[D]) GetConfig() *AuditClientConfig

func (*BaseAuditClient[D]) GetLogger 

func (bac *BaseAuditClient[D]) GetLogger() logger.Logger

func (*BaseAuditClient[D]) GetRequestMetadata 

func (bac *BaseAuditClient[D]) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)

func (*BaseAuditClient[D]) RequireTransportSecurity 

func (bac *BaseAuditClient[D]) RequireTransportSecurity() bool

func (*BaseAuditClient[D]) Start 

func (bac *BaseAuditClient[D]) Start(ctx context.Context) error

func (*BaseAuditClient[D]) Stop 

func (bac *BaseAuditClient[D]) Stop(stopTimeout time.Duration) error

type RawGRPCClientConfig 

type RawGRPCClientConfig struct {
	Secure           bool
	ConnTimeout      time.Duration
	KATime           time.Duration
	KATimeOut        time.Duration
	KAPermitWOStream bool
}

func NewRawGRPCClientConfig 

func NewRawGRPCClientConfig(
	secure bool,
	connTimeout time.Duration,
	KATime time.Duration,
	KATimeOut time.Duration,
	KAPermitWOStream bool,
) *RawGRPCClientConfig

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.