service

Documentation

Index

• type AccountService
  • func NewAccountService(system actors.ActorSystem, remoting *actors.Remoting, logger log.Logger, ...) *AccountService
  • func (s *AccountService) CreateAccount(ctx context.Context, c *connect.Request[samplepb.CreateAccountRequest]) (*connect.Response[samplepb.CreateAccountResponse], error)
  • func (s *AccountService) CreditAccount(ctx context.Context, c *connect.Request[samplepb.CreditAccountRequest]) (*connect.Response[samplepb.CreditAccountResponse], error)
  • func (s *AccountService) GetAccount(ctx context.Context, c *connect.Request[samplepb.GetAccountRequest]) (*connect.Response[samplepb.GetAccountResponse], error)
  • func (s *AccountService) Start()
  • func (s *AccountService) Stop(ctx context.Context) error
• type Config
  • func GetConfig() (*Config, error)

Types

type AccountService

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

func NewAccountService

func NewAccountService(system actors.ActorSystem, remoting *actors.Remoting, logger log.Logger, port int) *AccountService

NewAccountService creates an instance of AccountService

func (*AccountService) CreateAccount

func (s *AccountService) CreateAccount(ctx context.Context, c *connect.Request[samplepb.CreateAccountRequest]) (*connect.Response[samplepb.CreateAccountResponse], error)

CreateAccount helps create an account

func (*AccountService) CreditAccount

func (s *AccountService) CreditAccount(ctx context.Context, c *connect.Request[samplepb.CreditAccountRequest]) (*connect.Response[samplepb.CreditAccountResponse], error)

CreditAccount helps credit a given account

func (*AccountService) GetAccount

func (s *AccountService) GetAccount(ctx context.Context, c *connect.Request[samplepb.GetAccountRequest]) (*connect.Response[samplepb.GetAccountResponse], error)

GetAccount helps get an account

func (*AccountService) Start

func (s *AccountService) Start()

Start starts the service

func (*AccountService) Stop

func (s *AccountService) Stop(ctx context.Context) error

Stop stops the service

type Config

type Config struct {
	Port            int    `env:"PORT" envDefault:"50051"`
	ServiceName     string `env:"SERVICE_NAME"`
	ActorSystemName string `env:"SYSTEM_NAME"`
	GossipPort      int    `env:"GOSSIP_PORT"`
	PeersPort       int    `env:"PEERS_PORT"`
	RemotingPort    int    `env:"REMOTING_PORT"`
}

Config defines the service configuration

func GetConfig

func GetConfig() (*Config, error)

GetConfig returns the configuration