client

Documentation

Index

• func NewDecisionMakerClient(keyConfig config.KeyConfig, mtlsCfg config.MTLSConfig) (domain.DecisionMakerAdapter, error)
• type DecisionMakerClient
  • func (dm *DecisionMakerClient) DeleteSchedulingIntents(ctx context.Context, decisionMaker *domain.DecisionMakerPod, ...) error
  • func (dm *DecisionMakerClient) GetIntentMerkleRoot(ctx context.Context, decisionMaker *domain.DecisionMakerPod) (string, error)
  • func (dm *DecisionMakerClient) GetPodPIDMapping(ctx context.Context, decisionMaker *domain.DecisionMakerPod) (*domain.PodPIDMappingResponse, error)
  • func (dm *DecisionMakerClient) GetToken(ctx context.Context, decisionMaker *domain.DecisionMakerPod) (string, error)
  • func (dm *DecisionMakerClient) SendSchedulingIntent(ctx context.Context, decisionMaker *domain.DecisionMakerPod, ...) error

Functions

func NewDecisionMakerClient

func NewDecisionMakerClient(keyConfig config.KeyConfig, mtlsCfg config.MTLSConfig) (domain.DecisionMakerAdapter, error)

Types

type DecisionMakerClient

type DecisionMakerClient struct {
	*http.Client
	// contains filtered or unexported fields
}

func (*DecisionMakerClient) DeleteSchedulingIntents

func (dm *DecisionMakerClient) DeleteSchedulingIntents(ctx context.Context, decisionMaker *domain.DecisionMakerPod, req *domain.DeleteIntentsRequest) error

func (*DecisionMakerClient) GetIntentMerkleRoot

func (dm *DecisionMakerClient) GetIntentMerkleRoot(ctx context.Context, decisionMaker *domain.DecisionMakerPod) (string, error)

func (*DecisionMakerClient) GetPodPIDMapping

func (dm *DecisionMakerClient) GetPodPIDMapping(ctx context.Context, decisionMaker *domain.DecisionMakerPod) (*domain.PodPIDMappingResponse, error)

func (*DecisionMakerClient) GetToken

func (dm *DecisionMakerClient) GetToken(ctx context.Context, decisionMaker *domain.DecisionMakerPod) (string, error)

func (*DecisionMakerClient) SendSchedulingIntent

func (dm *DecisionMakerClient) SendSchedulingIntent(ctx context.Context, decisionMaker *domain.DecisionMakerPod, intents []*domain.ScheduleIntent) error