server

Documentation

Index

• type StrikeServer
  • func (s *StrikeServer) Login(ctx context.Context, clientLogin *pb.LoginRequest) (*pb.ServerResponse, error)
  • func (s *StrikeServer) MessageStream(username *pb.Username, stream pb.Strike_PayloadStreamServer) error
  • func (s *StrikeServer) SaltMine(ctx context.Context, user *pb.Username) (*pb.Salt, error)
  • func (s *StrikeServer) SendPayload(ctx context.Context, payload *pb.StreamPayload) (*pb.ServerResponse, error)
  • func (s *StrikeServer) Signup(ctx context.Context, userInit *pb.InitUser) (*pb.ServerResponse, error)
  • func (s *StrikeServer) UserStatus(req *pb.StatusRequest, stream pb.Strike_UserStatusServer) error

Types

type StrikeServer

type StrikeServer struct {
	pb.UnimplementedStrikeServer
	Env         []*pb.Envelope
	DBpool      *pgxpool.Pool
	PStatements *db.PreparedStatements

	OnlineUsers     map[string]pb.Strike_UserStatusServer
	PayloadStreams  map[string]pb.Strike_PayloadStreamServer
	PayloadChannels map[string]chan *pb.StreamPayload
	// contains filtered or unexported fields
}

func (*StrikeServer) Login

func (s *StrikeServer) Login(ctx context.Context, clientLogin *pb.LoginRequest) (*pb.ServerResponse, error)

func (*StrikeServer) MessageStream

func (s *StrikeServer) MessageStream(username *pb.Username, stream pb.Strike_PayloadStreamServer) error

func (*StrikeServer) SaltMine

func (s *StrikeServer) SaltMine(ctx context.Context, user *pb.Username) (*pb.Salt, error)

func (*StrikeServer) SendPayload

func (s *StrikeServer) SendPayload(ctx context.Context, payload *pb.StreamPayload) (*pb.ServerResponse, error)

func (*StrikeServer) Signup

func (s *StrikeServer) Signup(ctx context.Context, userInit *pb.InitUser) (*pb.ServerResponse, error)

func (*StrikeServer) UserStatus

func (s *StrikeServer) UserStatus(req *pb.StatusRequest, stream pb.Strike_UserStatusServer) error